Interface Stage.Skip
-
- All Superinterfaces:
Stage
- Enclosing interface:
- Stage
public static interface Stage.Skip extends Stage
A skip stage.The first
skip
elements must be skipped, after that all elements must be emitted.If the number of elements to skip is zero, this stage has no effect.
If less than
skip
elements are emitted before termination, then the termination must be propagated downstream as normal.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.eclipse.microprofile.reactive.streams.operators.spi.Stage
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
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description long
getSkip()
The number of elements to skip.
-