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.
Observable.create(…)) when I get called back by a hot source of data I don't control, is there a way to ensure that
onNextsucceeds immediately and does not block until the subscriber has finished handling it?
onNextcalls that should not block -> onBackpressureLatest -> one-at-a-time lengthy processing
samplewith a timeout of zero, or use one of the back pressure operators, probably the one with drop.
Flowablemakes things easier :-)