Interface Stage
- All Known Subinterfaces:
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
public interface Stage
A stage of a Reactive Streams graph.
A Reactive Streams engine will walk a graph of stages to produce Publisher
,
Subscriber
and Processor
instances that handle the stream
according to the sequence of stages.
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic interface
A cancelling stage.static interface
A collect stage.static interface
Concatenate the given graphs together.static interface
A stage that couples a wrapped subscriber graph to a wrapped publisher graph.static interface
A stage returning a stream consisting of the distinct elements (according toObject.equals(Object)
) of this stream.static interface
A drop while stage.static interface
A failed publisher.static interface
A filter stage.static interface
A subscriber stage that emits the first element encountered.static interface
A flat map stage.static interface
A flat map stage that emits and flattensCompletionStage
.static interface
A flat map stage that emits and fattensIterable
.static interface
A publisher representation of aCompletionStage
.static interface
A publisher representation of aCompletionStage
.static interface
A limit stage.static interface
A map stage.static interface
A publisher of zero to many values.static interface
A stage returning a stream containing all the elements from this stream, additionally performing the provided action when this stream completes.static interface
A stage returning a stream containing all the elements from this stream, additionally performing the provided action if this stream conveys an error.static interface
A stage to handle errors from upstream.static interface
A stage to handle errors from upstream.static interface
A stage returning a stream containing all the elements from this stream, additionally performing the provided action if this stream terminates with an error, completes, or is cancelled by downstream.static interface
A stage returning a stream containing all the elements from this stream, additionally performing the provided action on each element.static interface
A processor stage.static interface
A publisher stage.static interface
A skip stage.static interface
A subscriber.static interface
A take while stage.