Package io.quarkus.vertx.runtime

Class VertxNonBlockingProvider

java.lang.Object

io.quarkus.vertx.runtime.VertxNonBlockingProvider

All Implemented Interfaces:

io.quarkus.arc.spi.NonBlockingProvider

public class VertxNonBlockingProvider
extends Object
implements io.quarkus.arc.spi.NonBlockingProvider

This is used by the Quarkus Arc extension to delegate non-blocking @Startup methods to VertxContextSupport without depending on this extension

Constructor Summary

Constructors

Constructor	Description
VertxNonBlockingProvider()

Method Summary

Modifier and Type	Method	Description
<T> T	subscribeAndAwait(Supplier<io.smallrye.mutiny.Uni<T>> uniSupplier)

Methods inherited from class java.lang.Object

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

Constructor Details

VertxNonBlockingProvider

public VertxNonBlockingProvider()

Method Details

subscribeAndAwait

public <T> T subscribeAndAwait(Supplier<io.smallrye.mutiny.Uni<T>> uniSupplier)
                        throws Throwable

Specified by:

subscribeAndAwait in interface io.quarkus.arc.spi.NonBlockingProvider

Throws:

Throwable