Package io.smallrye.mutiny.streams.utils

Class WrappedProcessor<T>

java.lang.Object
io.smallrye.mutiny.streams.utils.WrappedProcessor<T>
All Implemented Interfaces:
org.reactivestreams.Processor<T,T>, org.reactivestreams.Publisher<T>, org.reactivestreams.Subscriber<T>
public class WrappedProcessor<T> extends Object implements org.reactivestreams.Processor<T,T>
Processor wrapping a publisher and subscriber, and connect them

  • Constructor Details

    • WrappedProcessor

      public WrappedProcessor(org.reactivestreams.Subscriber<T> subscriber, org.reactivestreams.Publisher<T> publisher)

  • Method Details

    • subscribe

      public void subscribe(org.reactivestreams.Subscriber<? super T> subscriber)
      Specified by:
      subscribe in interface org.reactivestreams.Publisher<T>

    • onSubscribe

      public void onSubscribe(org.reactivestreams.Subscription subscription)
      Specified by:
      onSubscribe in interface org.reactivestreams.Subscriber<T>

    • onNext

      public void onNext(T item)
      Specified by:
      onNext in interface org.reactivestreams.Subscriber<T>

    • onError

      public void onError(Throwable throwable)
      Specified by:
      onError in interface org.reactivestreams.Subscriber<T>

    • onComplete

      public void onComplete()
      Specified by:
      onComplete in interface org.reactivestreams.Subscriber<T>