RXJAVA EXTENDED: WRITING YOUR FIRST CUSTOM OPERATOR
summary
Shows how to implement real RxJava 2 operators in Java: bridges non‑reactive Android APIs (clicks, seekbar, MaterialDialogs) into reactive streams using MainThreadDisposable and proper Disposable wiring, and how to write an intermediate map+filter operator that handles upstream and downstream disposal. Demonstrates pitfalls of using Observable.create without setting the emitter Disposable (causes memory leaks), explains backpressure with a concrete incident of 81,000 updates that blew up the UI, and provides production‑ready patterns that work.
AI-written summary · about
chapters (9)
- 0:00Introduction and speaker intro
- 1:48Overview of RxJava and backpressure
- 5:15Anatomy of custom operators
- 6:18Creating a click operator
- 11:35Implementing intermediate operators
- 16:50Common pitfalls and anti-patterns
- 21:02When to use custom operators
- 23:06Advanced RxJava topics overview
- 25:53Resources and Q&A
