RxJava and long-running tasks parallelization
summary
Shows how RxJava actually parallelizes per-user calls to two blocking services (getName and getAge) using flatMap and Schedulers, merges their results with groupBy + collect + take(2), and emits each aggregated {id,name,age} as soon as both parts arrive. Implementation is a few dozen lines (the demo claims about 5–10 real lines for the core logic), uses standard Observables, a custom collector, and a fixed thread pool scheduler, and runs correctly without rewriting the existing synchronous architecture.
AI-written summary · about
chapters (9)
- 0:00Welcome
- 5:22What is RxJava
- 10:02Observables and Observers
- 17:16Parallel task execution
- 20:28Service example solution
- 27:54Blocking data issue
- 29:16Optimizing with take
- 31:22Why RxJava is loved
- 35:19Q&A
related talks
39mRx Concurrency: A Prescription for Multi-threading
20mLean Async Code with Kotlin's Coroutines
33mUntangle your App: Efficient Threading in Android
48mVisualiser l'API de concurrence Java
42mI Swapped RxJava for Coroutines. Why You Should Too
26mCoroutines and Rx: A Battle Towards Asynchronicity
28mInside Android asynchronous processing: Understanding the Event Loop
37mAndroid Suspenders