Go with the Flow!
summary
Shows that Flow operators are easy to write and actually usable: implements partition, takeUntil, groupBy with Kotlin coroutines and compares lines of code to Rx (thousands in legacy Rx vs tens in Flow). Uses channelFlow and channels to produce per-key streams, handles send/receive semantics, cancellation and closing downstreams, and fixes backpressure by choosing buffer strategy. Live code compiles and runs with concurrent collectors; the gotchas are buffer capacity choices (unlimited buffer vs rendezvous) and ensuring downstreams close on errors.
AI-written summary · about
chapters (6)
- 0:00Kotlin Flows intro
- 1:48Partition operator in Kotlin
- 10:34takeUntil with coroutines
- 19:03groupBy operator
- 32:22Kotlin vs RX Java operators
- 35:34Summary & Q&A
