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 interfaceA cancelling stage.static interfaceA collect stage.static interfaceConcatenate the given graphs together.static interfaceA stage that couples a wrapped subscriber graph to a wrapped publisher graph.static interfaceA stage returning a stream consisting of the distinct elements (according toObject.equals(Object)) of this stream.static interfaceA drop while stage.static interfaceA failed publisher.static interfaceA filter stage.static interfaceA subscriber stage that emits the first element encountered.static interfaceA flat map stage.static interfaceA flat map stage that emits and flattensCompletionStage.static interfaceA flat map stage that emits and fattensIterable.static interfaceA publisher representation of aCompletionStage.static interfaceA publisher representation of aCompletionStage.static interfaceA limit stage.static interfaceA map stage.static interfaceA publisher of zero to many values.static interfaceA stage returning a stream containing all the elements from this stream, additionally performing the provided action when this stream completes.static interfaceA stage returning a stream containing all the elements from this stream, additionally performing the provided action if this stream conveys an error.static interfaceA stage to handle errors from upstream.static interfaceA stage to handle errors from upstream.static interfaceA 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 interfaceA stage returning a stream containing all the elements from this stream, additionally performing the provided action on each element.static interfaceA processor stage.static interfaceA publisher stage.static interfaceA skip stage.static interfaceA subscriber.static interfaceA take while stage.