Module io.helidon.microprofile.reactive

Package io.helidon.microprofile.reactive

Class HelidonReactiveStreamsEngine

java.lang.Object

io.helidon.microprofile.reactive.HelidonReactiveStreamsEngine

All Implemented Interfaces:

ReactiveStreamsEngine

public final class HelidonReactiveStreamsEngine
extends Object
implements ReactiveStreamsEngine

Implementation of Reactive Streams with operators backed by Helidon reactive streams.

See Also:

• INSTANCE
• ReactiveStreamsEngine

Field Summary

Fields

Modifier and Type	Field	Description
static final HelidonReactiveStreamsEngine	INSTANCE	The singleton instance.

Constructor Summary

Constructors

Constructor	Description
HelidonReactiveStreamsEngine()

Method Summary

Modifier and Type	Method	Description
<T> CompletionStage<T>	buildCompletion(Graph graph)
<T, R> Processor<T,R>	buildProcessor(Graph graph)
<T> Publisher<T>	buildPublisher(Graph graph)
<T, R> SubscriberWithCompletionStage<T,R>	buildSubscriber(Graph graph)
static void	setCoupledExecutor(ExecutorService executor)	Override the ExecutorService used by the cross-termination and cross-cancellation of a Coupled stage.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

INSTANCE

public static final HelidonReactiveStreamsEngine INSTANCE

The singleton instance.

Constructor Details

HelidonReactiveStreamsEngine

public HelidonReactiveStreamsEngine()

Method Details

buildPublisher

public <T> Publisher<T> buildPublisher(Graph graph)
                                throws UnsupportedStageException

Specified by:

buildPublisher in interface ReactiveStreamsEngine

Throws:

UnsupportedStageException

buildSubscriber

public <T,
R> SubscriberWithCompletionStage<T,R> buildSubscriber(Graph graph)
                                                          throws UnsupportedStageException

Specified by:

buildSubscriber in interface ReactiveStreamsEngine

Throws:

UnsupportedStageException

buildProcessor

public <T,
R> Processor<T,R> buildProcessor(Graph graph)
                                     throws UnsupportedStageException

Specified by:

buildProcessor in interface ReactiveStreamsEngine

Throws:

UnsupportedStageException

buildCompletion

public <T> CompletionStage<T> buildCompletion(Graph graph)
                                       throws UnsupportedStageException

Specified by:

buildCompletion in interface ReactiveStreamsEngine

Throws:

UnsupportedStageException

setCoupledExecutor

public static void setCoupledExecutor(ExecutorService executor)

Override the ExecutorService used by the cross-termination and cross-cancellation of a Coupled stage.

Parameters:

executor - the executor to use, null resets it to the default ForkJoinPool