bulk-cdk-core-load/io.airbyte.cdk.load.config/SyncBeanFactory/OpenStreamQueue

OpenStreamQueue

@Singleton
@Named(value = "openStreamQueue")
class OpenStreamQueue : ChannelMessageQueue<DestinationStream>

A queue of streams to open on. This allows the dev to control the number of concurrent calls to open by controlling how many workers (coroutines) are pulling from this queue.

Constructors

Link copied to clipboard
constructor()

Properties

Link copied to clipboard
val channel: Channel<DestinationStream>

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 override fun consume(): Flow<DestinationStream>
Link copied to clipboard
open override fun isClosedForPublish(): Boolean
Link copied to clipboard
open suspend override fun poll(): DestinationStream?
Link copied to clipboard
open suspend override fun publish(message: DestinationStream)