Airbyte Kotlin Bulk CDK

0.1.92

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

ChannelMessageQueue

open class ChannelMessageQueue<T>(val channel: Channel<T>) : MessageQueue<T>

Inheritors

OpenStreamQueue

CheckpointMessageQueue

MultiProducerChannel

Constructors

ChannelMessageQueue

constructor(channel: Channel<T>)

Properties

val channel: Channel<T>

Functions

open suspend override fun close()

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

open override fun consume(): Flow<T>

isClosedForPublish

open override fun isClosedForPublish(): Boolean

open suspend override fun poll(): T?

open suspend override fun publish(message: T)