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

Message

interface Message<T> : MessageReader<T> , MessageWriter<T>

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