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

MessageQueue

interface MessageQueue<T> : QueueReader<T> , QueueWriter<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 fun consume(): Flow<T>
Link copied to clipboard
abstract fun isClosedForPublish(): Boolean
Link copied to clipboard
abstract suspend fun poll(): T?
Link copied to clipboard
abstract suspend fun publish(message: T)