Package io.smallrye.mutiny.vertx

Class AsyncResultUni<T>

java.lang.Object
io.smallrye.mutiny.operators.AbstractUni<T>
io.smallrye.mutiny.vertx.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

    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, onSubscription, onTermination, repeat, runSubscriptionOn, subscribe, subscribe, toMulti, 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.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, onSubscription, onTermination, plug, repeat, replaceIfNullWith, replaceIfNullWith, replaceWith, replaceWith, replaceWith, replaceWithNull, replaceWithVoid, runSubscriptionOn, stage, subscribe, subscribeAsCompletionStage, subscribeAsCompletionStage, toMulti, withContext

  • Constructor Details

    • AsyncResultUni

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

  • Method Details

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