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.
Disposable.disposeis not called from downstream on an
onComplete()unlike in 1.x where the
unsubscribe. The standard way of dealing with resources along a stream is
using()and performing final action via
I need to convert some callbacks to ReactiveX elements (Observable, Completable, Subject), but I am not sure what to pick. The problem is that the callback provides no value so it should be Completable but it is triggered multiple times so it should be Observable. What to choose? the normal use is this:
socket.on("connect", args -> doSomething())
where I know that args are always empty array.
Observable<java.lang.Void>be a good idea in this case?
so that's really the best way to deal with this?
thats too bad.. I think there should be another top-level class (such as Subject, Completable) that would solve this more elegantly