StrictPartitionedQueue

Constructors

constructor(queues: Array<MessageQueue<T>>)

open override val partitions: Int

open fun asOrderedFlows(): Array<Flow<T>>

open suspend override fun broadcast(value: T)

open suspend override fun close()

open override fun consume(partition: Int): Flow<T>

open suspend override fun publish(value: T, partition: Int)