Package io.smallrye.mutiny.vertx

Class AsyncResultUni<T>

  • All Implemented Interfaces:
    io.smallrye.mutiny.Uni<T>
    public class AsyncResultUni<T>
extends io.smallrye.mutiny.operators.AbstractUni<T>
implements io.smallrye.mutiny.Uni<T>

    • Constructor Summary

      Constructors 
      Constructor Description
      AsyncResultUni​(Consumer<io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>> subscriptionConsumer)  

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void subscribe​(io.smallrye.mutiny.subscription.UniSubscriber<? super T> downstream)  
      static <T> io.smallrye.mutiny.Uni<T> toUni​(Consumer<io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>> subscriptionConsumer)  

      • Methods inherited from class io.smallrye.mutiny.operators.AbstractUni

        await, awaitUsing, cache, convert, emitOn, ifNoItem, log, log, memoize, onCancellation, onFailure, onFailure, onFailure, onItem, onItemOrFailure, onSubscribe, onSubscription, onTermination, repeat, runSubscriptionOn, subscribe, subscribe, toMulti, withContext

      • Methods inherited from interface io.smallrye.mutiny.Uni

        attachContext, await, awaitUsing, call, call, chain, chain, convert, emitOn, eventually, eventually, flatMap, ifNoItem, invoke, invoke, log, log, map, memoize, onCancellation, onFailure, onFailure, onFailure, onItem, onItemOrFailure, onSubscribe, onSubscription, onTermination, plug, repeat, replaceIfNullWith, replaceIfNullWith, replaceWith, replaceWith, replaceWith, replaceWithNull, replaceWithVoid, runSubscriptionOn, stage, subscribe, subscribeAsCompletionStage, subscribeAsCompletionStage, toMulti, withContext

    • Constructor Detail

      • AsyncResultUni

        public AsyncResultUni​(Consumer<io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>> subscriptionConsumer)

    • Method Detail

      • toUni

        public static <T> io.smallrye.mutiny.Uni<T> toUni​(Consumer<io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>> subscriptionConsumer)

      • subscribe

        public void subscribe​(io.smallrye.mutiny.subscription.UniSubscriber<? super T> downstream)
        Specified by:
        subscribe in class io.smallrye.mutiny.operators.AbstractUni<T>