@@ -530,23 +530,20 @@ sealed interface DurableFuture<T> {
530530 * Like [kotlinx.coroutines.awaitAll], but for [DurableFuture].
531531 *
532532 * ```
533- * val ctx = restateContext()
534- * val a1 = ctx.callAsync(GreeterGrpcKt.greetMethod, greetingRequest { name = "Francesco" })
535- * val a2 = ctx.callAsync(GreeterGrpcKt.greetMethod, greetingRequest { name = "Till" })
533+ * val a1 = ctx.awakeable<String>()
534+ * val a2 = ctx.awakeable<String>()
536535 *
537536 * val result = listOf(a1, a2)
538537 * .awaitAll()
539- * .joinToString(separator = "-", transform = GreetingResponse::getMessage )
538+ * .joinToString(separator = "-")
540539 * ```
541540 */
542541suspend fun <T > Collection<DurableFuture<T>>.awaitAll (): List <T > {
543542 return awaitAll(* toTypedArray())
544543}
545544
546545/* *
547- * Like [kotlinx.coroutines.awaitAll], but for [DurableFuture].
548- *
549- * ```
546+ * @see Collection.awaitAll
550547 */
551548suspend fun <T > awaitAll (vararg durableFutures : DurableFuture <T >): List <T > {
552549 if (durableFutures.isEmpty()) {
@@ -563,9 +560,9 @@ suspend fun <T> awaitAll(vararg durableFutures: DurableFuture<T>): List<T> {
563560 * Like [kotlinx.coroutines.selects.select], but for [DurableFuture]
564561 *
565562 * ```
566- * val ctx = restateContext()
567- * val callFuture = ctx.callAsync(GreeterGrpcKt.greetMethod, greetingRequest { name = "Francesco" })
563+ * val callFuture = ctx.awakeable()
568564 * val timeout = ctx.timer(10.seconds)
565+ *
569566 * val result = select {
570567 * callFuture.onAwait { it.message }
571568 * timeout.onAwait { throw TimeoutException() }
0 commit comments