- All Superinterfaces:
- Enclosing interface:
public static interface Stage.Coupled extends StageA stage that couples a wrapped subscriber graph to a wrapped publisher graph.
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:
Lifecycle signal propagation 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
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