public static interface Stage.Map extends Stage
The given mapper function must be invoked on each element consumed, and the output of the function must be emitted.
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 |
---|---|
Function<?,?> |
getMapper()
The mapper function.
|
Function<?,?> getMapper()
Copyright © 2019 Eclipse Foundation. All rights reserved.