public static interface Stage.Peek extends Stage
The given consumer function must be invoked on each element consumed.
Any RuntimeException
thrown by the function must be propagated downstream as an error, and upstream
must be cancelled. Any subsequent elements received from upstream before the cancellation signal is handled
must be dropped.
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<?> |
getConsumer()
The consumer function.
|
Consumer<?> getConsumer()
Copyright © 2019 Eclipse Foundation. All rights reserved.