These are chat archives for ReactiveX/RxJava

7th
Feb 2017
Luciano
@lJoublanc
Feb 07 2017 10:02
@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.
Alexander Shpak
@alex-shpak
Feb 07 2017 10:22
@flozano @lJoublanc
I think .toList().toBlocking().first() should to the trick. And yes, you don't need to subscribe
Luciano
@lJoublanc
Feb 07 2017 10:24
@alex-shpak Not sure the he wants everything to be buffered.. not quite clear in his question.