Achieving Concurrency in RxJava
summary
Explains concurrency issues in RxJava and concrete fixes: shows that flatMap with maxConcurrency can still race, demonstrates using observeOn vs subscribeOn and Schedulers to separate I/O and computation, and uses TestScheduler-based unit tests to reproduce a duplicated-emission race. Builds a concurrent fetch pipeline that reduces end-to-end latency ~3× and verifies the race fix with deterministic tests so concurrency is measurable and repeatable.
AI-written summary · about
chapters (6)
- 0:00RxJava concurrency intro
- 1:42RxJava schedulers
- 5:41Concurrency examples
- 10:45Thread safety
- 15:23Best practices
- 19:36Q&A
