30         client_agent_tx: Arc<mpsc::Sender<ClientAgent>>,  in start()  argument
44         client_agent_tx: Arc<mpsc::Sender<ClientAgent>>,  in start()  argument
56 …                     if client_agent_tx.send(ClientAgent::Collect(Instant::now())).await.is_err() {  in start()
216     client_agent_tx: Option<Arc<mpsc::Sender<ClientAgent>>>,
224         client_agent_tx: Arc<mpsc::Sender<ClientAgent>>,  in read_until_closed()  argument
240                         if client_agent_tx.send(ClientAgent::Process(msg.clone())).await.is_err(){  in read_until_closed()
282         client_agent_tx: Arc<mpsc::Sender<ClientAgent>>,  in start()  argument
330                             .send(ClientAgent::Start(id, timeout))  in start()
344                                 let _ = client_agent_tx.send(ClientAgent::Stop(id)).await;  in start()
374             let _ = client_agent_tx.send(ClientAgent::Close).await;  in close()
451                     .send(ClientAgent::Start(m.transaction_id, d))  in send()
463                         .send(ClientAgent::Stop(m.transaction_id))  in send()