Lines Matching refs:recv

176     let _nb = conn_b.recv(&mut buf).await?;  in test_agent_get_stats()
236 let _ = callback_called_rx.recv().await; in test_on_selected_candidate_pair_change()
481 let _ = accepting_rx.recv().await; in test_connectivity_on_startup()
486 let _ = accepted_rx.recv().await; in test_connectivity_on_startup()
490 let _ = a_connected.recv().await; in test_connectivity_on_startup()
491 let _ = b_connected.recv().await; in test_connectivity_on_startup()
565 let _ = a_connected.recv().await; in test_connectivity_lite()
566 let _ = b_connected.recv().await; in test_connectivity_lite()
581 async fn recv(&self, _buf: &mut [u8]) -> std::result::Result<usize, util::Error> { in recv() method
1011 let _ = is_checking_rx.recv().await; in test_connection_state_callback()
1013 let _ = is_connected_rx.recv().await; in test_connection_state_callback()
1015 let _ = is_disconnected_rx.recv().await; in test_connection_state_callback()
1017 let _ = is_failed_rx.recv().await; in test_connection_state_callback()
1023 let _ = is_closed_rx.recv().await; in test_connection_state_callback()
1669 let _ = is_failed_rx.recv().await; in test_connection_state_failed_delete_all_candidates()
1837 let _ = cancel_rx.recv().await; in test_agent_restart_one_side()
1906 let _ = a_connected.recv().await; in test_agent_restart_both_side()
1907 let _ = b_connected.recv().await; in test_agent_restart_both_side()
1998 let _ = is_connected_rx.recv().await; in test_close_in_connection_state_callback()
2001 let _ = is_closed_rx.recv().await; in test_close_in_connection_state_callback()
2049 let _ = is_complete_rx.recv().await; in test_run_task_in_connection_state_callback()
2113 let _ = is_complete_rx.recv().await; in test_run_task_in_selected_candidate_pair_change_callback()
2114 let _ = is_tested_rx.recv().await; in test_run_task_in_selected_candidate_pair_change_callback()
2187 let _ = a_connected_rx.recv().await; in test_lite_lifecycle()
2188 let _ = b_connected_rx.recv().await; in test_lite_lifecycle()
2191 let _ = b_disconnected_rx.recv().await; in test_lite_lifecycle()
2192 let _ = b_failed_rx.recv().await; in test_lite_lifecycle()