Go with the Flow
summary
Kotlin Flow is built on coroutines and claims to be a cold, structured-concurrency implementation of Reactive Streams that interoperates with RxJava via official adapters and a custom rx01 artifact used at Clue. Examples show callbackFlow wrapping listener callbacks, stateFlow replaces ConflatedBroadcastChannel for state, channels used sparingly, and testing done with runBlocking and kotlinx-coroutines-test. Migration guidance includes evaluating options, adding foundation and tests, gradual API duplication, and a concrete migration path from RxJava 0/1 to Flow used in production though some features remain work in progress.
AI-written summary · about
chapters (14)
- 0:00Intro
- 0:51Synchronous code
- 1:37With Coroutines
- 7:07What's special
- 9:18What is Flow?
- 15:23RxJava example
- 26:14Discuss with your team
- 28:26Setup foundation TT
- 30:01Expose common features as Flow
- 31:31Setup safeguards
- 35:59Terminology between Rx and Coroutine
- 38:24Conclusion
- 38:53Final thoughts
- 39:13Further resources
