56 …                     if client_agent_tx.send(ClientAgent::Collect(Instant::now())).await.is_err() {  in start()
96                 handler.send(e)?;  in handle()
240                         if client_agent_tx.send(ClientAgent::Process(msg.clone())).await.is_err(){  in read_until_closed()
255             handler_tx.send(Event {  in insert()
270             handler_tx.send(Event {  in remove()
313                                 let _ = handler.send(event);  in start()
330                             .send(ClientAgent::Start(id, timeout))  in start()
336                                 let _ = handler.send(event);  in start()
343                             if c.send(&raw).await.is_err() {  in start()
344                                 let _ = client_agent_tx.send(ClientAgent::Stop(id)).await;  in start()
348                                     let _ = handler.send(event);  in start()
374             let _ = client_agent_tx.send(ClientAgent::Close).await;  in close()
429     pub async fn send(&mut self, m: &Message, handler: Handler) -> Result<()> {  in send()  method
451                     .send(ClientAgent::Start(m.transaction_id, d))  in send()
457             let result = c.send(&m.raw).await;  in send()
463                         .send(ClientAgent::Stop(m.transaction_id))  in send()