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 © 2018 – 2022 Eclipse Foundation. All rights reserved.
Use is subject to license terms.