These are chat archives for ReactiveX/RxJava

Jan 2018
Mark Galea
Jan 05 2018 22:05
@akarnokd I'm reading the Rx Code and your blog and I have a question about the merge operator. Why is the main queue an SPSC instance (rather than MPSC) give that inner subscribers can call the parent.tryEmit(this, t); concurrently. Or is this impossible?
David Karnok
Jan 05 2018 23:33
That SPSC queue is for the the main Observables that turn out to be of scalar origin, such as 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.