sdk-api-kotlin/dev.restate.sdk.kotlin/awaitAll

awaitAll

suspend fun <T> Collection<DurableFuture<T>>.awaitAll(): List<T>

Like kotlinx.coroutines.awaitAll, but for DurableFuture.

val ctx = restateContext()
val a1 = ctx.callAsync(GreeterGrpcKt.greetMethod, greetingRequest { name = "Francesco" })
val a2 = ctx.callAsync(GreeterGrpcKt.greetMethod, greetingRequest { name = "Till" })

val result = listOf(a1, a2)
  .awaitAll()
  .joinToString(separator = "-", transform = GreetingResponse::getMessage)

suspend fun <T> awaitAll(vararg durableFutures: DurableFuture<T>): List<T>

Like kotlinx.coroutines.awaitAll, but for DurableFuture.