ProtobufDestinationMessageInputFlow
class ProtobufDestinationMessageInputFlow(inputStream: InputStream, reader: ProtobufDataChannelReader) : Flow<DestinationMessage> (source)
Performs non-cooperative blocking IO. Does not respond directly to coroutine CancellationExceptions.