usagi/dimensional.usagi.channel.consumer/Consumer

Consumer

data class Consumer(val channel: Channel, val tag: String)

Constructors

fun Consumer(channel: Channel, tag: String)

Types

object Companion

Functions

suspend fun cancel(noWait: Boolean = false)

Cancel this consumer.

suspend fun wait()

Suspends until this consumer has been cancelled.

fun waitAsync(): Deferred<Unit>

Properties

val channel: Channel

val deliveries: SharedFlow<Delivery>

val scope: CoroutineScope

val tag: String

Extensions

inline fun Consumer.forEach(scope: CoroutineScope = this.scope, noinline block: suspend (Delivery) -> Unit): Job