stdioHeartbeatTask

@Singleton

@Requires(property = "airbyte.destination.core.data-channel.medium", value = "STDIO")

fun stdioHeartbeatTask(@Named(value = "_pipelineInputQueue") pipelineInputQueue: PartitionedQueue<PipelineInputEvent>? = null, config: DestinationConfiguration, checkpointManager: CheckpointManager): HeartbeatTask

Because sockets will be implemented as cold flows, the heartbeat behavior will have to reside in the readers.