Package io.smallrye.mutiny.streams.operators

package io.smallrye.mutiny.streams.operators

Related Packages

Package	Description
io.smallrye.mutiny.streams
io.smallrye.mutiny.streams.spi
io.smallrye.mutiny.streams.stages
io.smallrye.mutiny.streams.utils

Class	Description
Operator<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage>
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.
ProcessorOperator<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage>
PublisherOperator<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage>
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.
TerminalOperator<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage>
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.