Package io.smallrye.mutiny.streams

Class Engine

java.lang.Object
io.smallrye.mutiny.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
    Description
    Engine()
     

  • Method Summary

    Modifier and Type
    Method
    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 Details

    • Engine

      public Engine()

  • Method Details

    • 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