bulk-cdk-toolkit-legacy-task-loader/io.airbyte.cdk.load.message/ChannelMessage

ChannelMessage

abstract class ChannelMessage<T> : Message<T> (source)

Constructors

constructor()

Properties

val channel: Channel<T>

Functions

open suspend override fun close()

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

open suspend override fun get(): T?

open suspend override fun publish(message: T)