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.
someObservable.toBlocking().toFuture()block? Many methods on this page describe blocking. In the description of
toFuture()blocking isn't mentioned.
singleon your source to enforce the contract of a single value, and will block if you call
get(), block for a maximum of timeout and throw
TimeoutExceptionif you call