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

QueueWriter

interface QueueWriter<T> : CloseableCoroutine

Inheritors

Functions

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 isClosedForPublish(): Boolean
Link copied to clipboard
abstract suspend fun publish(message: T)