common/io.facet.common/await

await

suspend fun <T : Any> Flux<T>.await(): List<T>
Content copied to clipboard

Suspends the current coroutine, and returns all elements emitted by the Flux in a List.


@JvmName(name = "awaitVoid")
suspend fun Flux<Void>.await()
Content copied to clipboard

Suspends the current coroutine, and returns when the Flux completes.


suspend fun <T : Any> Mono<T>.await(): T
Content copied to clipboard

Awaits for the single value from the given Mono, suspending the current coroutine and resuming when the mono emits the resulting value or throws the corresponding exception if this publisher had produced error.

This suspending function is cancellable. If the Job of the current coroutine is cancelled or completed while this suspending function is waiting, this function immediately resumes with CancellationException.

Throws

if mono does not emit any value


@JvmName(name = "awaitVoid")
suspend fun Mono<Void>.await()
Content copied to clipboard

Awaits for the completion signal from the given Mono, suspending the current coroutine and resuming when the mono emits the resulting value or throws the corresponding exception if this publisher had produced error.

This suspending function is cancellable. If the Job of the current coroutine is cancelled or completed while this suspending function is waiting, this function immediately resumes with CancellationException.