30         client_agent_tx: Arc<mpsc::Sender<ClientAgent>>,  in start()
44         client_agent_tx: Arc<mpsc::Sender<ClientAgent>>,  in start()
56 …                     if client_agent_tx.send(ClientAgent::Collect(Instant::now())).await.is_err() {  in start()
216     client_agent_tx: Option<Arc<mpsc::Sender<ClientAgent>>>,  field
224         client_agent_tx: Arc<mpsc::Sender<ClientAgent>>,  in read_until_closed()
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()
329                         if client_agent_tx  in start()
344                                 let _ = client_agent_tx.send(ClientAgent::Stop(id)).await;  in start()
373         if let Some(client_agent_tx) = &mut self.client_agent_tx {  in close()
374             let _ = client_agent_tx.send(ClientAgent::Close).await;  in close()
376         self.client_agent_tx.take();  in close()
387         let (client_agent_tx, client_agent_rx) = mpsc::channel(self.settings.buffer_size);  in run()
391         let client_agent_tx = Arc::new(client_agent_tx);  in run()  localVariable
393         self.client_agent_tx = Some(Arc::clone(&client_agent_tx));  in run()
406             Arc::clone(&client_agent_tx),  in run()
418             collector.start(self.settings.rto_rate, Arc::clone(&client_agent_tx))?;  in run()
423             async move { Client::read_until_closed(close_rx, conn_rx, client_agent_tx).await },  in run()
449             if let Some(client_agent_tx) = &mut self.client_agent_tx {  in send()
450                 client_agent_tx  in send()
461                 if let Some(client_agent_tx) = &mut self.client_agent_tx {  in send()
462                     client_agent_tx  in send()