kotlin-common-vertx/com.huanshankeji.vertx.kotlin.coroutines

Package-level declarations

Types

CoroutineCombinedVerticleFunctions

interface CoroutineCombinedVerticleFunctions : CombinedVerticleFunctions

CoroutineVerticleI

interface CoroutineVerticleI : Verticle, CoroutineScope

Functions

awaitAll

suspend fun <T> List<Future<T>>.awaitAll(): List<T>

Awaits the completion of all the futures in the list without blocking the event loop, and fails as soon as any future fails.

awaitExecuteBlocking

suspend fun <T> Vertx.awaitExecuteBlocking(blockingCode: () -> T): T

Execute blockingCode that returns the a T instance with Vertx.executeBlocking and awaits its completion.

awaitSuspendExecuteBlocking

suspend fun <T> Vertx.~~awaitSuspendExecuteBlocking~~(blockingCode: suspend () -> T): T

Like awaitExecuteBlocking but blockingCode is a suspend function.

coroutineToFuture

fun <T> CoroutineScope.coroutineToFuture(context: CoroutineContext = EmptyCoroutineContext, start: CoroutineStart = CoroutineStart.DEFAULT, block: suspend CoroutineScope.() -> T): Future<T>

Launch a coroutine and converts it into a Future that completes when the suspended function returns and fails if it throws.

use

inline suspend fun <R> Vertx.use(block: (Vertx) -> R): R

Execute the block code and close the Vertx instance like kotlin.use on an AutoCloseable.