bulk-cdk-core-load/io.airbyte.cdk.load.message/PartitionedQueue

PartitionedQueue

interface PartitionedQueue<T> : CloseableCoroutine

Inheritors

Properties

Link copied to clipboard
abstract val partitions: Int

Functions

Link copied to clipboard
open fun asOrderedFlows(): Array<Flow<T>>
Link copied to clipboard
abstract suspend fun broadcast(value: T)
Link copied to clipboard
abstract suspend fun close()
Link copied to clipboard
inline suspend fun CloseableCoroutine.closeFinally(cause: Throwable?)
Link copied to clipboard
abstract fun consume(partition: Int): Flow<T>
Link copied to clipboard
abstract suspend fun publish(value: T, partition: Int)