Package io.smallrye.reactive.streams.operators

Interface Summary

Interface	Description
ProcessingStage<I,O>	Defines a processing stage - so a stream transformation.
ProcessingStageFactory<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage>	Factory to create ProcessingStage instances.
PublisherStage<O>	Specialization of the ProcessingStage for data sources (publishers).
PublisherStageFactory<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage>	Factory to create PublisherStage instances.
TerminalStage<I,O>	Defines a terminal stage - so a stream subscription and observation.
TerminalStageFactory<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage>	Factory to create TerminalStage instances.

Class Summary

Class	Description
Operator<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage>
ProcessorOperator<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage>
PublisherOperator<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage>
TerminalOperator<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage>