Package io.quarkus.arc.runtime

Class NonBlockingSupport

java.lang.Object

io.quarkus.arc.runtime.NonBlockingSupport

public class NonBlockingSupport
extends Object

Utility class that allows invoking non-blocking startup methods on non-blocking threads when the Quarkus Vert.x extension is present (which provides us with support for this). This is used to avoid a circular dependency with it. This is also checked at build time so we should never have a runtime error.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ERROR_MSG

Constructor Summary

Constructors

Constructor	Description
NonBlockingSupport()

Method Summary

Modifier and Type	Method	Description
static <T> T	subscribeAndAwait(Supplier<io.smallrye.mutiny.Uni<T>> uniSupplier)	Delegates this call to the declared NonBlockingProvider implementation, hopefully Quarkus Vert.x, if it is available.

Methods inherited from class java.lang.Object

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

Field Details

ERROR_MSG

public static final String ERROR_MSG

See Also:

• Constant Field Values

Constructor Details

NonBlockingSupport

public NonBlockingSupport()

Method Details

subscribeAndAwait

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

Delegates this call to the declared NonBlockingProvider implementation, hopefully Quarkus Vert.x, if it is available.

Throws:

RuntimeException - if the Quarkus Vert.x extension is not present.

Throwable

See Also:

• NonBlockingProvider.subscribeAndAwait(Supplier)