These are chat archives for ReactiveX/RxJava
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
Subscriberthat sets up the listener in the
onNextmethod. When the listener callback fires, it calls
onNexton the subscriber that handles the output
subscribeOnthread -- it's being handled inside a DrmManagerClient event handler thread
subscribeOnscheduler (in this example,
Schedulers.io)? If so, what is the best way to do that?
Object#notify, but I was hoping there might be something more idiomatic to RxJava)