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.
Is this a bug? I would have expected this to eventually terminate but it never does
ConnectableFlowable<Integer> publish = Flowable.just(1) .publish(); Disposable subscribe = publish.subscribe((e)->System.out.println(e)); publish.connect(); publish.blockingSubscribe();
This is the latest rxJava
publishcompleted and is awaiting for the next
connect()call. Otherwise, it is a shortcoming of the
ConnectableXAPI we aim to fix in 3.x: ReactiveX/RxJava#5628