bulk-cdk-toolkit-legacy-task-loader/io.airbyte.cdk.load.file/ProtobufDataChannelReader

ProtobufDataChannelReader

class ProtobufDataChannelReader(factory: DestinationMessageFactory, bufferSize: Int = 16 * 1024) : DataChannelReader(source)

Performs non-cooperative blocking IO.

Constructors

Link copied to clipboard
constructor(factory: DestinationMessageFactory, bufferSize: Int = 16 * 1024)

Functions

Link copied to clipboard
open override fun read(inputStream: InputStream): Sequence<DestinationMessage>
Generated by Dokka
© 2026 Copyright