usagi/dimensional.usagi.channel.consumer

Package-level declarations

Types

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

data class Delivery(val consumer: Consumer, val envelope: Delivery.Envelope, val properties: AMQP.Basic.Properties, val data: ByteArray)

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