These are chat archives for ReactiveX/RxJava

16th
Jun 2016
Dmitry V. Roenko
@Eternity-Yarr
Jun 16 2016 12:31
Hey all! Can anyone explain to me this behavior: https://gist.github.com/Eternity-Yarr/93dd29aa90824cb92c53494c8330a601?ts=2 ?
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
@Eternity-Yarr
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
@Eternity-Yarr
Jun 16 2016 12:43
okay! found it :)) it's because of flatMap
thanks!