public static interface Stage.Limit extends Stage
Only limit
elements may be emitted, once that many elements are emitted, downstream must be completed,
and upstream must be cancelled. Any subsequent elements received from upstream before the cancellation signal
is handled must be dropped.
If less than limit
elements are received before termination, then the termination must be propagated
downstream as normal.
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 |
---|---|
long |
getLimit()
The limit.
|
Copyright © 2019 Eclipse Foundation. All rights reserved.