Marcin Moskala в своей книги Kotlin Coroutines Deep Dive наглядно показывает как устроены Flow под капотом:
Все гениальное просто 😎
#Coroutines #Flow
fun interface FlowCollector<T> {
suspend fun emit(value: T)
}
interface Flow<T> {
suspend fun collect(collector: FlowCollector<T>)
}
fun <T> flow(
builder: suspend FlowCollector<T>.() -> Unit
) = object : Flow<T> {
override suspend fun collect(
collector: FlowCollector<T>
) {
collector.builder()
}
}
suspend fun main() {
val f: Flow<String> = flow {
emit("A")
emit("B")
emit("C")
}
f.collect { print(it) } // ABC
f.collect { print(it) } // ABC
}
Все гениальное просто 😎
#Coroutines #Flow
❤2