public static interface Stage.OnError extends Stage
The given consumer function must be invoked with the conveyed failure.
Any RuntimeException
thrown by the function must be propagated downstream as an error, replacing the
exception that the consumer 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 |
---|---|
Consumer<Throwable> |
getConsumer()
The error handler.
|
Copyright © 2019 Eclipse Foundation. All rights reserved.