Package io.smallrye.mutiny.streams.operators

Interface ProcessingStageFactory<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage>

All Known Implementing Classes:

CoupledStageFactory, DistinctStageFactory, DropWhileStageFactory, FilterStageFactory, FlatMapCompletionStageFactory, FlatMapIterableStageFactory, FlatMapStageFactory, LimitStageFactory, MapStageFactory, OnCompleteStageFactory, OnErrorResumeStageFactory, OnErrorResumeWithStageFactory, OnErrorStageFactory, OnTerminateStageFactory, PeekStageFactory, ProcessorStageFactory, SkipStageFactory, TakeWhileStageFactory

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface ProcessingStageFactory<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage>

Factory to create ProcessingStage instances.

Author:

Clement Escoffier

Method Summary

Modifier and Type	Method	Description
<I, O> ProcessingStage<I,O>	create(Engine engine, T stage)	Creates the instance.

Method Details

create

<I,
O> ProcessingStage<I,O> create(Engine engine,
 T stage)

Creates the instance.

Type Parameters:

I - input data

O - output data

Parameters:

engine - the reactive engine

stage - the stage

Returns:

the created processing stage, should never be null