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.
parent.tryEmit(this, t);concurrently. Or is this impossible?
just. Since these come through
onNext, there is guarantted to be one producer of them. The drain will then read from this SPSC queue and the queues of the inner
Subscribers from a guaranteed single thread at a time.