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.
subscription.onErrorbe called immediately or maybe after some timeout? Or maybe behaviour should depend on signalled demand?
take(1)will unsubscribe after 1 element, but could stay connected forever if there are no elements.
takeUntilcan end after a timeout if you combine it with an
timeoutthat gives an error if it takes too long. Also usefull