public static interface Stage.Concat extends Stage
Each graph must have an outlet and no inlet.
The resulting publisher produced by the concat stage must emit all the elements from the first graph, and once that graph emits a completion signal, it must then subscribe to and emit all the elements from the second. If an error is emitted by the either graph, the error must be emitted from the resulting stream.
If processing terminates early while the first graph is still emitting, either due to that graph emitting an error, or due to a cancellation signal from downstream, then the second graph must be subscribed to and cancelled. This is to ensure that any hot publishers holding onto resources that may be backing the graphs are cleaned up.
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 |
---|---|
Graph |
getFirst()
The first graph in the stream.
|
Graph |
getSecond()
The second graph in the stream.
|
Copyright © 2019 Eclipse Foundation. All rights reserved.