Function scheduled_sinks 

pub fn scheduled_sinks<P, T>(
    transport: T,
    config: LogStreamSenderConfig,
    clock: RobotClock,
) -> CuResult<(ScheduledCopperListSink<P>, ScheduledKeyFrameSink, SenderMonitor)>
where
    P: CopperListTuple + Send + Sync,
    T: CuStreamTx + 'static,

Start one autonomous worker with an explicitly selected local RobotClock. A real carrier must use a running clock even when application time is mocked. Drops of both sinks stop repetition, then drain at most max_latency in local clock time. No application object, serialization, or wait is added to the RT path.