Lines Matching refs:channel

190     let (callback_called_tx, mut callback_called_rx) = mpsc::channel::<()>(1);  in test_on_selected_candidate_pair_change()
459 let (accepted_tx, mut accepted_rx) = mpsc::channel::<()>(1); in test_connectivity_on_startup()
460 let (accepting_tx, mut accepting_rx) = mpsc::channel::<()>(1); in test_connectivity_on_startup()
461 let (_a_cancel_tx, a_cancel_rx) = mpsc::channel(1); in test_connectivity_on_startup()
462 let (_b_cancel_tx, b_cancel_rx) = mpsc::channel(1); in test_connectivity_on_startup()
875 let (_cancel_tx1, cancel_rx1) = mpsc::channel(1); in test_invalid_agent_starts()
882 let (_cancel_tx2, cancel_rx2) = mpsc::channel(1); in test_invalid_agent_starts()
889 let (cancel_tx3, cancel_rx3) = mpsc::channel(1); in test_invalid_agent_starts()
901 let (_cancel_tx4, cancel_rx4) = mpsc::channel(1); in test_invalid_agent_starts()
958 let (is_checking_tx, mut is_checking_rx) = mpsc::channel::<()>(1); in test_connection_state_callback()
959 let (is_connected_tx, mut is_connected_rx) = mpsc::channel::<()>(1); in test_connection_state_callback()
960 let (is_disconnected_tx, mut is_disconnected_rx) = mpsc::channel::<()>(1); in test_connection_state_callback()
961 let (is_failed_tx, mut is_failed_rx) = mpsc::channel::<()>(1); in test_connection_state_callback()
962 let (is_closed_tx, mut is_closed_rx) = mpsc::channel::<()>(1); in test_connection_state_callback()
1656 let (is_failed_tx, mut is_failed_rx) = mpsc::channel::<()>(1); in test_connection_state_failed_delete_all_candidates()
1742 let (_cancel_tx, cancel_rx) = mpsc::channel(1); in test_connection_state_connecting_to_failed()
1751 let (_cancel_tx, cancel_rx) = mpsc::channel(1); in test_connection_state_connecting_to_failed()
1823 let (cancel_tx, mut cancel_rx) = mpsc::channel::<()>(1); in test_agent_restart_one_side()
1978 let (is_closed_tx, mut is_closed_rx) = mpsc::channel::<()>(1); in test_close_in_connection_state_callback()
1979 let (is_connected_tx, mut is_connected_rx) = mpsc::channel::<()>(1); in test_close_in_connection_state_callback()
2035 let (is_complete_tx, mut is_complete_rx) = mpsc::channel::<()>(1); in test_run_task_in_connection_state_callback()
2087 let (is_tested_tx, mut is_tested_rx) = mpsc::channel::<()>(1); in test_run_task_in_selected_candidate_pair_change_callback()
2099 let (is_complete_tx, mut is_complete_rx) = mpsc::channel::<()>(1); in test_run_task_in_selected_candidate_pair_change_callback()
2159 let (b_connected_tx, mut b_connected_rx) = mpsc::channel::<()>(1); in test_lite_lifecycle()
2160 let (b_disconnected_tx, mut b_disconnected_rx) = mpsc::channel::<()>(1); in test_lite_lifecycle()
2161 let (b_failed_tx, mut b_failed_rx) = mpsc::channel::<()>(1); in test_lite_lifecycle()