Channel 和 Flow 都是数据流，Channel 是“热”的，Flow 则是“冷”的。这里的冷，代表着 Flow 不仅是“冷淡”的，而且还是“懒惰”的。

Flow 从 API 的角度分类，主要分为：构造器、中间操作符、终止操作符。今天这节课，我们将会从这几个角度来分析 Flow 的源码，来看看它的这几类 API 是如何实现的。

Flow 的功能看起来非常高大上，然而它的原理却非常的简单

// 代码段1fun main() {val scope = CoroutineScope(Job())scope.launch {testFlow()}Thread.sleep(1000L)logX("end")
}private suspend fun testFlow() {// 1flow {emit(1)emit(2)emit(3)emit(4)emit(5)}.collect {      // 2logX(it)}
}/*** 控制台输出带协程信息的log*/
fun logX(any: Any?) {println("""
================================
$any
Thread:${Thread.currentThread().name}
================================""".trimIndent())
}/*
输出结果
================================
1
Thread:DefaultDispatcher-worker-1
================================
================================
2
Thread:DefaultDispatcher-worker-1
================================
================================
3
Thread:DefaultDispatcher-worker-1
================================
================================
4
Thread:DefaultDispatcher-worker-1
================================
================================
5
Thread:DefaultDispatcher-worker-1
================================
================================
end
Thread:main
================================
*/

这段代码很简单，我们创建了一个 CoroutineScope，接着使用它创建了一个新的协程，在协程当中，我们使用 flow{} 这个高阶函数创建了 Flow 对象，接着使用了 collect{} 这个终止操作符。