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

MultiProducerChannel

class MultiProducerChannel<T>(producerCount: Long, channel: Channel<T>, name: String) : ChannelMessageQueue<T>

A channel designed for use with a fixed amount of producers. Close will be called on the underlying channel, when there are no remaining registered producers.

Constructors

constructor(producerCount: Long, channel: Channel<T>, name: String)

Properties

channel

val channel: Channel<T>

Functions

open suspend override fun close()

closeFinally

inline suspend fun CloseableCoroutine.closeFinally(cause: Throwable?)

consume

open override fun consume(): Flow<T>

isClosedForPublish

open override fun isClosedForPublish(): Boolean

poll

open suspend override fun poll(): T?

publish

open suspend override fun publish(message: T)