Intro to RxJava
summary
Claims that RxJava makes Android async code explicit, composable and easier to reason about by using observables with operators and subscribeOn/observeOn for thread control. Demonstrates concrete tools: create/fromIterable, map, filter, flatMap, merge, debounce; shows examples like debounced button clicks, flatMap cache-then-network fetch, file download on IO with onNext/onError/onComplete handling, and a local-broadcast SMS verification reader. Errors funnel to a single onError, subscriptions return tokens that can unsubscribe, and composed streams execute and complete as shown.
AI-written summary · about
chapters (15)
- 0:00Start
- 1:10Why Do We Need a Synchronous Work
- 4:34Evaluation Metrics
- 5:42Threads Management
- 8:19Three Key Points of Rx
- 9:21Observables
- 10:28Factory Analogy
- 11:22Key Phases of the Observable Life Cycle
- 11:56Observables with Iterable
- 13:23Pseudocode
- 17:11Perf Issues
- 18:13On Error
- 22:57Filter
- 23:27Combining and Merging Observables
- 34:02Debouncing a Button
related talks
44mExploring RxJava 2 for Android
39mReactive Android: RxJava and beyond
40mRxJava 2 for the rest of us
33mRXJAVA EXTENDED: WRITING YOUR FIRST CUSTOM OPERATOR
39mRx Concurrency: A Prescription for Multi-threading
32mUnderstanding the principles of Rx, Flow, Compose, and more, through Programming Paradigms
37mA Practical Guide To master Rx Streams
20mAchieving Concurrency in RxJava