You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Note that the interface Cancellable has been moved to rx.functions affecting CompletableEmitter and the experimental Observable.fromEmitter(Action1<AsyncEmitter<T>> emitter, AsyncEmitter.BackpressureMode backpressure) has been removed.
Another important clarification was added to the javadoc about using SingleSubscriber: due to the internal enhancements of Single, a SingleSubscriber is no longer wrapped into a Subscriber+SafeSubscriber which setup used to call unsubscribe on the SingleSubscriber yielding isUnsubscribed() == true when the source terminated. Therefore, when one extends the class SingleSubscriber, the unsubscribe() should be called manually to yield the given expecation mentioned before:
Version 1.2.2 - November 3, 2016 (Maven)
Note that the interface
Cancellable
has been moved torx.functions
affectingCompletableEmitter
and the experimentalObservable.fromEmitter(Action1<AsyncEmitter<T>> emitter, AsyncEmitter.BackpressureMode backpressure)
has been removed.Another important clarification was added to the javadoc about using
SingleSubscriber
: due to the internal enhancements ofSingle
, aSingleSubscriber
is no longer wrapped into aSubscriber
+SafeSubscriber
which setup used to callunsubscribe
on theSingleSubscriber
yieldingisUnsubscribed() == true
when the source terminated. Therefore, when one extends the classSingleSubscriber
, theunsubscribe()
should be called manually to yield the given expecation mentioned before:Documentation enhancements
timer
javadocSingleSubscriber
doc about unsubscribe invocation inonSuccess
andonError
.API enhancements
AsyncEmitter
deprecationscache()
toSingle
Performance enhancements
zip
- check local boolean before volatile in boolean andBugfixes
subscribe(Action1 [, Action1])
to reportisUnsubscribed
true after the callbacks were invokedObservable.switchIfEmpty
The text was updated successfully, but these errors were encountered: