connect_and_run

agentmux_srv::muxbus::cloud_subscriber

Function connect_and_run 

Source 
async fn connect_and_run(
    token: &str,
    agents: Arc<Mutex<HashSet<String>>>,
    ctrl_rx: &mut UnboundedReceiver<CtrlMsg>,
    _wstore: &Arc<Store>,
    http: &Client,
) -> Result<(), String>