bulk-cdk-core-load/io.airbyte.cdk.load.dataflow.input/ProtobufDestinationMessageInputFlow

ProtobufDestinationMessageInputFlow

class ProtobufDestinationMessageInputFlow(inputStream: InputStream, reader: ProtobufDataChannelReader) : Flow<DestinationMessage>

Performs non-cooperative blocking IO. Does not respond directly to coroutine CancellationExceptions.

Constructors

Link copied to clipboard
constructor(inputStream: InputStream, reader: ProtobufDataChannelReader)

Properties

Link copied to clipboard
val log: KLogger

Functions

Link copied to clipboard
open suspend override fun collect(collector: FlowCollector<DestinationMessage>)