public static interface Stage.Of extends Stage
When built, must produce a publisher that produces all the values (until cancelled) emitted by this iterables iterator, followed by completion of the stream.
Any exceptions thrown by the iterator must be propagated downstream, or by the invocation of the iterator
method, must be propagated downstream.
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 |
---|---|
Iterable<?> |
getElements()
The elements to emit.
|
Iterable<?> getElements()
Copyright © 2018 – 2022 Eclipse Foundation. All rights reserved.
Use is subject to license terms.