Building Responsive Applications with RxKotlin
summary
Shows concrete RxKotlin code that wires an observable to a subscriber with onNext/onError/onComplete callbacks, demonstrates a marble diagram for stream transformation and error recovery, and highlights managing lifecycle with Disposable. Uses examples that filter, map, merge and schedule a message stream, argues RxKotlin simplifies handling heavy streaming loads and recovering from mid-stream errors, and contrasts this message-oriented model with coroutines’ sequential “heartbeat” approach.
AI-written summary · about
chapters (11)
- 0:00Introduction
- 2:37Reactive programming
- 5:30Solving problems reactively
- 6:35Reactive X overview
- 8:45Marble diagrams
- 10:19Emissions and observers
- 12:33Reactive processes
- 15:23RxKotlin vs coroutines
- 16:32Q&A: Data integrity
- 18:42Q&A: RxKotlin vs coroutines
- 20:31Closing
related talks
32mRX Java with Kotlin in Baby Steps
39mAdvanced Networking with RxJava + Retrofit
42mAndroid reactive programming with Rxjava
32mUnderstanding the principles of Rx, Flow, Compose, and more, through Programming Paradigms
37mA Practical Guide To master Rx Streams
49mKotlin Reactive Programming Patterns
43mFunctional approach to Android architecture using Kotlin
51mManaging State with RxJava