2.1.1
Notable changes
The emitter API (such as FlowableEmitter
, SingleEmitter
, etc.) now features a new method, tryOnError
that tries to emit the Throwable
if the sequence is not cancelled/disposed. Unlike the regular onError
, if the downstream is no longer willing to accept events, the method returns false and doesn't signal an UndeliverableException
.
API enhancements
- Pull 5344: Add
tryOnError
tocreate/XEmitter
API. - Pull 5386: Add
subscribeOn
overload to avoid same-pool deadlock with create.
Documentation changes
- Pull 5343: Fix Javadoc for
Maybe.toSingle
. - Pull 5347: Fix Javadoc for
FunctionX
- Pull 5351: Update some marbles of
Observable
- Commit b4aeb6e3: Replace
Action1
withConsumer
in docs. - Pull 5383: Fixed Javadoc for
SingleFlatMapIterableObservable
. - Pull 5403: Fix the copy-paste error in the Javadoc of
Single.doAfterTeminate
mentioningdoAfterSuccess
. - Pull 5405:
DefaultObserver
javadoc fix: use subscribe, remove disposable code. - Pull 5407:
DefaultSubscriber
javadoc sample fix. - Pull 5406: Fix javadoc for
Observable.reduce()
andObservable.reduceWith()
. - Pull 5409: Corrected
Single.delay
documentation.
Bugfixes
- Pull 5367: Make sure
interval+trampoline
can be stopped. - Pull 5378: Make
SingleMap
not allow map function return null. - Pull 5379: Add missing null checks on values returned by user functions.
- Pull 5415: Fix
doOnNext
failure not triggeringdoOnError
when fused. - Pull 5419: Fix periodic scheduling with negative period causing IAE.
- Pull 5427: Fix
buffer(time, maxSize)
duplicating buffers on time-size race.