public static interface Stage.OnErrorResumeWith extends Stage
By default, when a stream encounters an error that prevents it from emitting the expected item to its subscriber,
the stream (publisher) invokes its subscriber's onError
method, and then terminates without invoking
any more of its subscriber's methods. This operator changes this behavior. If the current stream encounters an
error, instead of invoking its subscriber's onError
method, it will instead relinquish control to
the PublisherBuilder
returned from given function. In such a case, because no publisher necessarily
invokes onError
, the subscriber may never know that an error happened.
Any elements emitted by the returned publisher must be sent downstream, in addition to its completion and error signals. If the returned publisher completes with an error, that error must not result in the recovery function on this stage being invoked again.
Any RuntimeException
thrown by the function must be propagated downstream as an error, replacing the
exception that the function was handling.
Stage.Cancel, Stage.Collect, Stage.Concat, Stage.Coupled, Stage.Distinct, Stage.DropWhile, Stage.Failed, Stage.Filter, Stage.FindFirst, Stage.FlatMap, Stage.FlatMapCompletionStage, Stage.FlatMapIterable, Stage.FromCompletionStage, Stage.FromCompletionStageNullable, Stage.Limit, Stage.Map, Stage.Of, Stage.OnComplete, Stage.OnError, Stage.OnErrorResume, Stage.OnErrorResumeWith, Stage.OnTerminate, Stage.Peek, Stage.ProcessorStage, Stage.PublisherStage, Stage.Skip, Stage.SubscriberStage, Stage.TakeWhile
Modifier and Type | Method and Description |
---|---|
Function<Throwable,Graph> |
getFunction()
The error handler.
|
Copyright © 2018 – 2022 Eclipse Foundation. All rights reserved.
Use is subject to license terms.