极客时间-轻松学习，高效学习-极客邦

Paul Shan
2022-04-06
Flow 接口引用了FlowCollector接口，并封装了一段调用逻辑，作为将来FlowCollector使用的来源。FlowCollector，带有emit函数的接口，统一了上游的发送方的数据输出和下游接收方的数据输入。FlowCollector的做法和通常扩展函数不太一样，通常的扩展函数是先有核心类，然后扩展函数扩充核心类的功能。FlowCollector是先在上游的构造器里构建了高阶的扩展函数，然后在下游collect里实现了带有emit的核心类。下游collect触发流程，然后上游的emit驱动下游的emit。这么设计原因应该是上游的构造器，相对复杂，而且是推迟执行的，需要给开发人员以足够的灵活性，所以采用了扩展函数的格式，下游接受数据相对固定，而且是同步执行的，采用固定的FlowCollector接口。
作者回复: 不错的答案，赞~
10
大土豆
2022-04-06
老师，下节课的目录得改下。。。应该是Android开发者还有未来吗？市场基本都没需求了
作者回复: 哈哈哈……Android开发的领域整体确实趋向于饱和了，不过中、高级的Android开发者还是比较稀缺的。
3
zyaire
2022-04-11
老师，“Flow 上游与下游的协程上下文就会不一致，它们整体的结构也会被破坏，从而导致“结构化并发”的特性也被破坏。”这句话不是很能理解，以代码11来说，即使在flow中调用withContext切换了上下文，当外部协程取消时，不也是会响应取消操作吗
作者回复: 如果你在flow当中，通过withContext()改变了它其中的Job层级，Flow就无法正常响应取消了。当然，withContext{}也可能只切换线程池，并不修改协程的父子结构，但Kotlin官方目前的做法是干脆全都禁止，想要切线程，就用统一的flowOn{}。否则，flow源码当中的判断条件会更加的复杂，这是Kotlin官方不愿意看见的。
共 2 条评论
1
再前进一点
2022-04-08
同问：为啥transform{}这方法在IDE里点击跳转到的源码是unsafeTransform这个方法呢
作者回复: 请留意它的import，Kotlin源码中经常这么用： ``` import kotlinx.coroutines.flow.unsafeTransform as transform ``` 类似的，还有：unsafeFlow as flow。
1
dawn
2022-04-08
@PublishedApi internal inline fun <T, R> Flow<T>.unsafeTransform( @BuilderInference crossinline transform: suspend FlowCollector<R>.(value: T) -> Unit ): Flow<R> = unsafeFlow { // Note: unsafe flow is used here, because unsafeTransform is only for internal use 这里的作用域应该是FlowCollector，为什么可以调用collect函数 collect { value -> // kludge, without it Unit will be returned and TCE won't kick in, KT-28938 return@collect transform(value) } } @PublishedApi internal inline fun <T> unsafeFlow(@BuilderInference crossinline block: suspend FlowCollector<T>.() -> Unit): Flow<T> { return object : Flow<T> { override suspend fun collect(collector: FlowCollector<T>) { collector.block() } } }
展开
作者回复: 因为它的扩展接收者是Flow呀，说实话，这部分的API挺巧妙的。
共 3 条评论
1
奇得隆冬强
2022-04-26
// 2 internal inline fun <T, R> Flow<T>.unsafeTransform( crossinline transform: suspend FlowCollector<R>.(value: T) -> Unit ): Flow<R> = unsafeFlow { // 6 collect { value -> // 7 return@collect transform(value) } } 老师，可以解答下么： 1、transform 的接受者是哪个实例呢？是 flow {}.filter {}.collect {} 中终止操作符号 collect 传入的 FlowCollector 还是注释 6 处 collect 传入的 FlowCollector 实例呢？按照逻辑的话，应该是终止操作符号 collect {} 传入的 FlowCollector。但是看逻辑，注释 6 处的 collect 的参数也是个 FlowCollector 实例，那么 transform 的接受者应该是它？？
作者回复: 答案：是 flow {}.filter {}.collect {} 中终止操作符号 collect 传入的 FlowCollector。这里用文字描述可能比较费劲，我试着解释一下： flow {}.filter {}.collect {}当中的 collect{} ，它传入的FlowCollector，是通过下面注释处，跟transform建立关系的。 ``` internal inline fun <T> unsafeFlow( crossinline block: suspend FlowCollector<T>.() -> Unit ): Flow<T> { return object : Flow<T> { override suspend fun collect(collector: FlowCollector<T>) { // 注意这里 collector.block() } } } ```
奇得隆冬强
2022-04-26
// 2 internal inline fun <T, R> Flow<T>.unsafeTransform ( crossinline transform: suspend FlowCollector<R>.(value: T) -> Unit ): Flow<R> = unsafeFlow { // 6 collect { value -> // 7 return@collect transform (value) } }
作者回复: 在你另一个回复里解答了哈~
奇得隆冬强
2022-04-26
// 代码段8 // 1 inline fun <T> Flow<T>.filter( crossinline predicate: suspend (T) -> Boolean ): Flow<T> = transform { value -> // 8 if (predicate(value)) return@transform emit(value) } // 2 internal inline fun <T, R> Flow<T>.unsafeTransform( crossinline transform: suspend FlowCollector<R>.(value: T) -> Unit ): Flow<R> = unsafeFlow { // 6 collect { value -> // 7 return@collect transform(value) } } // 3 internal inline fun <T> unsafeFlow( crossinline block: suspend FlowCollector<T>.() -> Unit ): Flow<T> { // 4 return object : Flow<T> { // 5 override suspend fun collect(collector: FlowCollector<T>) { collector.block() } } } 老师好，想在问一个问题： unsafeTransform 中的 collect 参数是一个 FlowCollector 匿名内部类实例那 return@collect transform(value) 中的 transform 的接收者是这个 FlowCollector 匿名内部类实例还是 flow{}.filter{}.collect{} 中，终止操作符传入的 FlowCollector 匿名内部类实例呢？？
展开
作者回复: 答案是：是 flow{}.filter{}.collect{} 中，终止操作符传入的 FlowCollector 匿名内部类实例。我在你另一个评论里解答了哈~
奇得隆冬强
2022-04-24
老师好，对于 Flow 的 fliter 的源码，确实没看懂，可以详细讲下么？？直接看源码不直观，反编译看 java 有很凌乱 // unsafeTransform // 2 inline fun <T> Flow<T>.unsafeTransform( crossinline transform: suspend FlowCollector<T>.(value: T) -> Unit // FlowCollector.transform ): Flow<T> { return unsafeFlow { // 这里的作用域应该是 FlowCollector，为什么可以调用 collect 函数 collect(object : FlowCollector<T> { override suspend fun emit(value: T) { // 7 transform(value) } }) // 6 // collect { value -> // // 7 // return@collect transform(value) // } } }
作者回复: 请留意你注释2处的，扩展接收者类型，它也是Flow。
奇得隆冬强
2022-04-23
难道说是因为 unsafeFlow 创建的是一个匿名内部类的实例，匿名内部类的实例是持有外部对象 SafeFlow 的引用？？？
作者回复: 是的
共 2 条评论