suspend fun waitForUpdates(): ReceiveChannel<Update> = produce {
  onUpdateHook { update ->
    send(update)
  }
}

fun startWaitingForUpdates() {
  launch {
    waitForUpdates().onReceive { update ->
      doUpdate(update)
    }
  }
}

suspendCoroutine

waitForUpdates

fun CoroutineScope.waitForUpdates(): ReceiveChannel<Update> = produce {
    onUpdateHook { update ->
        send(update)
        suspendCoroutine<Nothing> { /* do nothing */ }
    }
}

fun CoroutineScope.startWaitingForUpdates() {
    launch {
        waitForUpdates().apply {
            select {
                onReceive { update ->
                    doUpdate(update)
                }
            }
        }
    }
}

suspendCoroutine<Nothing> { /* do nothing */ }

fun CoroutineScope.waitForUpdates(): ReceiveChannel<Update> = produce {
    suspendCoroutine<Unit> { cont ->
        onUpdateHook { update ->
            send(update)
        }
        onUpdateTermination { error ->
            if (error != null) {
                cont.resumeWithException(error)
            }
            else {
                cont.resume(Unit)
            }
        }
    }
}

send

offer

onUpdateHook

suspend

offer

onUpdateHook

Channel()

suspend

suspend fun waitForUpdates(): ReceiveChannel<Update> = coroutineScope { ... }

coroutineScope

this

CoroutineScope