These are chat archives for ReactiveX/RxJava

Feb 2017
Feb 07 2017 10:02 UTC
@flozano Not sure if I recall correctly, but I don't think you have a 'subscribe' on blocking observable. Check the docs for 'BlockingObservable' - the answer to your Q depends on which call you use instead of 'subscribe'.
e.g. using latest or next not all elems would be buffered.
Alex Shpak
Feb 07 2017 10:22 UTC
@flozano @lJoublanc
I think .toList().toBlocking().first() should to the trick. And yes, you don't need to subscribe
Feb 07 2017 10:24 UTC
@alex-shpak Not sure the he wants everything to be buffered.. not quite clear in his question.