These are chat archives for ReactiveX/RxJava
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
nextnot all elems would be buffered.
.toList().toBlocking().first()should to the trick. And yes, you don't need to subscribe