Searched refs:conn_rx (Results 1 – 4 of 4) sorted by relevance
71 let conn_rx = Arc::clone(&conn); in test_udp_conn_send_to_recv_from() localVariable81 let (n, addr) = match conn_rx.recv_from(&mut buf).await { in test_udp_conn_send_to_recv_from()158 let conn_rx = Arc::clone(&conn); in test_udp_conn_send_recv() localVariable168 let n = match conn_rx.recv(&mut buf).await { in test_udp_conn_send_recv()
42 let conn_rx = Arc::clone(&conn); in chat() localVariable46 while let Ok(n) = conn_rx.recv(&mut b).await { in chat()
421 let conn_rx = Arc::clone(&conn); in run() localVariable423 async move { Client::read_until_closed(close_rx, conn_rx, client_agent_tx).await }, in run()
574 let conn_rx = Arc::clone(&conn); in test_net_virtual_loopback2() localVariable580 result = conn_rx.recv_from(&mut buf) => { in test_net_virtual_loopback2()