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

MessageWriter

interface MessageWriter<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 suspend fun publish(message: T)