These are chat archives for ReactiveX/RxJava

Jun 2016
Dmitry V. Roenko
Jun 16 2016 12:31
Hey all! Can anyone explain to me this behavior: ?
Basically I'm trying to create observable from infinite iterable
with some queue backing it. And it kinda works, except queue is always empty for some reason, even though producer supplies 1 item per 1ms and consumers is only 4 threads with 1 sec delay each
Dmitry V. Roenko
Jun 16 2016 12:36
I suspect that there is some unbounded queue somewhere deep inside of OnSubscribeFromIterable
MergeSubscriber.queue ?
looks like it..
Dmitry V. Roenko
Jun 16 2016 12:43
okay! found it :)) it's because of flatMap