io.smallrye.reactive.streams

Class Engine

java.lang.Object

io.smallrye.reactive.streams.Engine

All Implemented Interfaces:

org.eclipse.microprofile.reactive.streams.operators.spi.ReactiveStreamsEngine

public class Engine
extends Object
implements org.eclipse.microprofile.reactive.streams.operators.spi.ReactiveStreamsEngine

Constructor Summary

Constructors

Constructor and Description
Engine()

Method Summary

Modifier and Type	Method and Description
<T> CompletionStage<T>	buildCompletion(org.eclipse.microprofile.reactive.streams.operators.spi.Graph graph)
<T,R> org.reactivestreams.Processor<T,R>	buildProcessor(org.eclipse.microprofile.reactive.streams.operators.spi.Graph graph)
<T> org.reactivestreams.Publisher<T>	buildPublisher(org.eclipse.microprofile.reactive.streams.operators.spi.Graph graph)
<T,R> org.eclipse.microprofile.reactive.streams.operators.spi.SubscriberWithCompletionStage<T,R>	buildSubscriber(org.eclipse.microprofile.reactive.streams.operators.spi.Graph graph)

Methods inherited from class java.lang.Object

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

Constructor Detail

Engine

public Engine()

Method Detail

buildPublisher

public <T> org.reactivestreams.Publisher<T> buildPublisher(org.eclipse.microprofile.reactive.streams.operators.spi.Graph graph)

Specified by:

buildPublisher in interface org.eclipse.microprofile.reactive.streams.operators.spi.ReactiveStreamsEngine

buildSubscriber

public <T,R> org.eclipse.microprofile.reactive.streams.operators.spi.SubscriberWithCompletionStage<T,R> buildSubscriber(org.eclipse.microprofile.reactive.streams.operators.spi.Graph graph)

Specified by:

buildSubscriber in interface org.eclipse.microprofile.reactive.streams.operators.spi.ReactiveStreamsEngine

buildProcessor

public <T,R> org.reactivestreams.Processor<T,R> buildProcessor(org.eclipse.microprofile.reactive.streams.operators.spi.Graph graph)

Specified by:

buildProcessor in interface org.eclipse.microprofile.reactive.streams.operators.spi.ReactiveStreamsEngine

buildCompletion

public <T> CompletionStage<T> buildCompletion(org.eclipse.microprofile.reactive.streams.operators.spi.Graph graph)

Specified by:

buildCompletion in interface org.eclipse.microprofile.reactive.streams.operators.spi.ReactiveStreamsEngine