Skip to main content

coordinator_task

Function coordinator_task 

Source
pub async fn coordinator_task(
    serial_rx: Receiver<SerialEvent>,
    sender_tx: Sender<SenderMessage>,
    rcs_connector: ConnectorProxy,
) -> Result<()>
Expand description

Multiplexes FDomain channels between incoming SerialEvents and RCS toolbox sockets via rcs_connector, scheduling outgoing SenderMessages across active channels in round-robin order.

ยงErrors

Returns Ok(()) when serial_rx closes cleanly.