Package-level declarations
Types
Link copied to clipboard
class DataFlowPipelineInputFlow(inputFlow: Flow<DestinationMessage>, stateStore: StateStore, stateKeyClient: StateKeyClient, completionTracker: StreamCompletionTracker, statsStore: EmittedStatsStore) : Flow<DataFlowStageIO>
Takes DestinationMessages and emits DataFlowStageIO.
Link copied to clipboard
class JsonDestinationMessageInputFlow(inputStream: InputStream, deserializer: ProtocolMessageDeserializer) : Flow<DestinationMessage>
Takes bytes and emits DestinationMessages
Link copied to clipboard
class ProtobufDestinationMessageInputFlow(inputStream: InputStream, reader: ProtobufDataChannelReader) : Flow<DestinationMessage>
Performs non-cooperative blocking IO. Does not respond directly to coroutine CancellationExceptions.