Flowing in the Deep
summary
Shows how Kotlin Flow (built on Coroutines) implements streams: uses flow builder with suspendable collect/emit pair, reimplements map (example multiplies five 100ms-emitted values by two) and a working switchMap that launches inner flows and cancels the previous inner job on new emissions. Explains threading: use channelFlow and send to switch contexts, flowOn only affects upstream, backpressure is automatic, and the demo operators compile and run as shown.
AI-written summary · about
chapters (10)
- 0:00Introduction to Flow
- 1:53Problem with synchronous calls
- 6:06Observer pattern and Flow
- 10:20Building a Flow
- 13:30Handling errors in Flow
- 16:20Implementing the map operator
- 20:56Understanding switchMap
- 25:33Coroutine context and dispatchers
- 28:22Threading with Flow
- 34:04Useful Flow APIs
