Package io.smallrye.mutiny.streams.utils

Class WrappedSubscriber<T>

java.lang.Object
io.smallrye.mutiny.streams.utils.WrappedSubscriber<T>
All Implemented Interfaces:
org.reactivestreams.Subscriber<T>
public class WrappedSubscriber<T> extends Object implements org.reactivestreams.Subscriber<T>
Author:
Clement Escoffier

  • Constructor Details

    • WrappedSubscriber

      public WrappedSubscriber(org.reactivestreams.Subscriber<T> delegate)

  • Method Details

    • future

      public CompletionStage<Void> future()

    • 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>