Build Your Custom Rx Observable/Operator
summary
Shows how to wrap Google Play Services Nearby Messaging as RxJava primitives by implementing a custom Observable for subscribing/listening and a custom Operator for publishing. Explains creating a new API client per subscribe, wiring the Nearby listener to call onNext/onError, registering teardown to disconnect on unsubscribe, and handling backpressure via setProducer. Points out common implementation pitfalls and references RxJava operator-implementation guidance.
AI-written summary · about
chapters (7)
- 0:00Start
- 0:58When do you need a custom Observable/Operator?
- 5:41Publishing a message
- 6:53What is an Observable? What is an Operator?
- 11:00Operator Example: map()
- 19:21Key Takeaways
- 21:05MessagePublishOperator
related talks
33mRXJAVA EXTENDED: WRITING YOUR FIRST CUSTOM OPERATOR
42mAndroid reactive programming with Rxjava
22mDemystifying RxJS Operators
32mRX Java with Kotlin in Baby Steps
22mBuilding Responsive Applications with RxKotlin
44mWhat are Observables and why should I care?
49mFunctional Reactive Programming with RxJava
47mRxJava by example – Volume 3 (the multicast edition)