spawn

nixfleet_agent::runtime::workers::outbound

Function spawn 

Source 
pub fn spawn(
    cfg: AgentConfig,
    queue: Arc<OutboundQueue>,
    kick_rx: Receiver<()>,
    _input_tx: Sender<ReducerInput>,
    shutdown: ShutdownToken,
) -> JoinHandle<()>