bulk-cdk-core-load/io.airbyte.cdk.load.config/DataChannelBeanFactory/stdioInputConsumerTask

stdioInputConsumerTask

@Singleton
@Requires(property = "airbyte.destination.core.data-channel.medium", value = "STDIO")
fun stdioInputConsumerTask(inputFlow: ReservingDeserializingInputFlow, @Named(value = "_pipelineInputQueue") pipelineInputQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>? = null, partitioner: InputPartitioner, pipelineEventBookkeepingRouter: PipelineEventBookkeepingRouter): InputConsumerTask

Sockets will be implemented as cold flows, so a task is only needed for reading from STDIO.