Class ReadStreamSubscriber<R,J>

java.lang.Object
io.smallrye.mutiny.vertx.ReadStreamSubscriber<R,J>
All Implemented Interfaces:
io.vertx.core.streams.ReadStream<J>, io.vertx.core.streams.StreamBase, Flow.Subscriber<R>

public class ReadStreamSubscriber<R,J> extends Object implements Flow.Subscriber<R>, io.vertx.core.streams.ReadStream<J>
  • Field Details

  • Constructor Details

    • ReadStreamSubscriber

      public ReadStreamSubscriber(Function<R,J> adapter)
  • Method Details

    • asReadStream

      public static <R, J> io.vertx.core.streams.ReadStream<J> asReadStream(Flow.Publisher<R> multi, Function<R,J> adapter)
    • handler

      public io.vertx.core.streams.ReadStream<J> handler(io.vertx.core.Handler<J> handler)
      Specified by:
      handler in interface io.vertx.core.streams.ReadStream<R>
    • pause

      public io.vertx.core.streams.ReadStream<J> pause()
      Specified by:
      pause in interface io.vertx.core.streams.ReadStream<R>
    • fetch

      public io.vertx.core.streams.ReadStream<J> fetch(long amount)
      Specified by:
      fetch in interface io.vertx.core.streams.ReadStream<R>
    • resume

      public io.vertx.core.streams.ReadStream<J> resume()
      Specified by:
      resume in interface io.vertx.core.streams.ReadStream<R>
    • onSubscribe

      public void onSubscribe(Flow.Subscription s)
      Specified by:
      onSubscribe in interface Flow.Subscriber<R>
    • endHandler

      public io.vertx.core.streams.ReadStream<J> endHandler(io.vertx.core.Handler<Void> handler)
      Specified by:
      endHandler in interface io.vertx.core.streams.ReadStream<R>
    • exceptionHandler

      public io.vertx.core.streams.ReadStream<J> exceptionHandler(io.vertx.core.Handler<Throwable> handler)
      Specified by:
      exceptionHandler in interface io.vertx.core.streams.ReadStream<R>
      Specified by:
      exceptionHandler in interface io.vertx.core.streams.StreamBase
    • onComplete

      public void onComplete()
      Specified by:
      onComplete in interface Flow.Subscriber<R>
    • onError

      public void onError(Throwable e)
      Specified by:
      onError in interface Flow.Subscriber<R>
    • onNext

      public void onNext(R item)
      Specified by:
      onNext in interface Flow.Subscriber<R>