Learning Rx by example
summary
Three concrete Rx examples for Android that actually show working code and outcomes rather than abstract promises: merging local DB and network without stale overwrites using merge + takeUntil + publish to share the network observable; an on‑scroll paginator built with a PublishSubject + flatMap/concatMap pipeline that preserves order and feeds page numbers back into the stream; and a production NTP client (true time) that does DNS resolution, fires five UDP requests per server, retries flaky calls, filters by round‑trip delay and takes the median using repeat + retry + from + compose — the library is open source and the solutions work as implemented.
AI-written summary · about
chapters (8)
- 0:00Introduction to Rx
- 1:52Anatomy of an Rx call
- 5:36Merging local and network data
- 9:53Sharing observables
- 14:57Pagination with subjects
- 24:25NTP time synchronization
- 25:39Implementing complex NTP logic
- 41:08Q&A session
related talks
39mReactive Android: RxJava and beyond
47mRxJava by example – Volume 3 (the multicast edition)
39mAdvanced Networking with RxJava + Retrofit
45mIntro to RxJava
27mPractical Rx with Flutter
42mAndroid reactive programming with Rxjava
48mGoing Reactive, An Android Architectural Journey
49mFunctional Reactive Programming with RxJava
