public static interface Stage.Coupled extends Stage
The resulting stage sends all the elements received to the passed in subscriber, and emits all the elements received from the passed in publisher.
In addition, the lifecycles of the subscriber and publisher are coupled, such that if one terminates or receives a termination signal, the other will be terminated. Below is a table of what signals are emited when:
Returned ProcessorBuilder inlet | Passed in SubscriberBuilder | Passed in PublisherBuilder | Returned ProcessorBuilder outlet |
---|---|---|---|
Cause: complete from upstream | Effect: complete | Effect: cancel | Effect: complete |
Cause: error from upstream | Effect: error | Effect: cancel | Effect: error |
Effect: cancel | Cause: cancels | Effect: cancel | Effect: complete |
Effect: cancel | Effect: complete | Cause: completes | Effect: complete |
Effect: cancel | Effect: error | Cause: errors | Effect: error |
Effect: cancel | Effect: complete | Effect: cancel | Cause: cancel from 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 |
---|---|
Graph |
getPublisher()
Get the publisher graph.
|
Graph |
getSubscriber()
Get the subscriber graph.
|
Copyright © 2019 Eclipse Foundation. All rights reserved.