Package io.smallrye.mutiny.vertx

Class MultiReadStream<T,U>

java.lang.Object
io.smallrye.mutiny.operators.AbstractMulti<U>
io.smallrye.mutiny.vertx.MultiReadStream<T,U>
All Implemented Interfaces:
io.smallrye.mutiny.Multi<U>, Flow.Publisher<U>
public class MultiReadStream<T,U> extends io.smallrye.mutiny.operators.AbstractMulti<U> implements io.smallrye.mutiny.Multi<U>

  • Constructor Summary

    Constructors
    Constructor
    Description
    MultiReadStream(io.vertx.core.streams.ReadStream<T> source, Function<T,U> transformation)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    subscribe(Flow.Subscriber<? super U> downstream)
     

    Methods inherited from class io.smallrye.mutiny.operators.AbstractMulti

    broadcast, cache, capDemandsUsing, collect, convert, emitOn, emitOn, group, ifNoItem, log, log, onCancellation, onCompletion, onFailure, onFailure, onFailure, onItem, onOverflow, onRequest, onSubscription, onTermination, paceDemand, runSubscriptionOn, select, skip, subscribe, subscribe, toHotStream, toUni, withContext

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface io.smallrye.mutiny.Multi

    attachContext, broadcast, cache, call, call, capDemandsTo, capDemandsUsing, collect, concatMap, convert, emitOn, emitOn, filter, flatMap, group, ifNoItem, invoke, invoke, log, log, map, onCancellation, onCompletion, onFailure, onFailure, onFailure, onItem, onOverflow, onRequest, onSubscription, onTermination, paceDemand, plug, runSubscriptionOn, select, skip, split, stage, subscribe, toHotStream, toUni, withContext

  • Constructor Details

    • MultiReadStream

      public MultiReadStream(io.vertx.core.streams.ReadStream<T> source, Function<T,U> transformation)

  • Method Details

    • subscribe

      public void subscribe(Flow.Subscriber<? super U> downstream)
      Specified by:
      subscribe in interface Flow.Publisher<T>
      Overrides:
      subscribe in class io.smallrye.mutiny.operators.AbstractMulti<U>