Searched refs:is_closed_tx (Results 1 – 1 of 1) sorted by relevance
962 let (is_closed_tx, mut is_closed_rx) = mpsc::channel::<()>(1); in test_connection_state_callback()968 let is_closed_tx = Arc::new(Mutex::new(Some(is_closed_tx))); in test_connection_state_callback() localVariable975 let is_closed_tx_clone = Arc::clone(&is_closed_tx); in test_connection_state_callback()1978 let (is_closed_tx, mut is_closed_rx) = mpsc::channel::<()>(1); in test_close_in_connection_state_callback()1980 let is_closed_tx = Arc::new(Mutex::new(Some(is_closed_tx))); in test_close_in_connection_state_callback() localVariable1983 let is_closed_tx_clone = Arc::clone(&is_closed_tx); in test_close_in_connection_state_callback()