public static interface Stage.OnComplete extends Stage
The given action must be called when the stream completes successfully. Use Stage.OnError
to handle failures,
and Stage.OnTerminate
if the action needs to be called for completion, error or cancellation.
Any RuntimeException
thrown by this function must be propagated downstream as an error.
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 |
---|---|
Runnable |
getAction()
The action to execute.
|
Runnable getAction()
Copyright © 2019 Eclipse Foundation. All rights reserved.