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

ChannelMessage

abstract class ChannelMessage<T> : Message<T>

Constructors

Link copied to clipboard
constructor()

Properties

Link copied to clipboard
val channel: Channel<T>

Functions

Link copied to clipboard
open suspend override fun close()
Link copied to clipboard
inline suspend fun CloseableCoroutine.closeFinally(cause: Throwable?)
Link copied to clipboard
open suspend override fun get(): T?
Link copied to clipboard
open suspend override fun publish(message: T)