168     let (conn_a, conn_b, agent_a, agent_b) = pipe(None, None).await?;  in test_agent_get_stats()
171     assert_eq!(agent_b.get_bytes_received(), 0);  in test_agent_get_stats()
172     assert_eq!(agent_b.get_bytes_sent(), 0);  in test_agent_get_stats()
181     assert_eq!(agent_b.get_bytes_received(), 10);  in test_agent_get_stats()
182     assert_eq!(agent_b.get_bytes_sent(), 0);  in test_agent_get_stats()
1749     let agent_b = Arc::clone(&b_agent);  in test_connection_state_connecting_to_failed()  localVariable
1752         let result = agent_b  in test_connection_state_connecting_to_failed()
1809     let (_, _, agent_a, agent_b) = pipe(  in test_agent_restart_one_side()
1825     agent_b.on_connection_state_change(Box::new(move |c: ConnectionState| {  in test_agent_restart_one_side()
1840     agent_b.close().await?;  in test_agent_restart_one_side()
1867     let (_, _, agent_a, agent_b) = pipe(  in test_agent_restart_both_side()
1884         generate_candidate_address_strings(agent_b.get_local_candidates().await);  in test_agent_restart_both_side()
1890     agent_b.on_connection_state_change(b_notifier);  in test_agent_restart_both_side()
1894     agent_b.restart("".to_owned(), "".to_owned()).await?;  in test_agent_restart_both_side()
1897     let (ufrag, pwd) = agent_b.get_local_user_credentials().await;  in test_agent_restart_both_side()
1901     agent_b.set_remote_credentials(ufrag, pwd).await?;  in test_agent_restart_both_side()
1903     gather_and_exchange_candidates(&agent_a, &agent_b).await?;  in test_agent_restart_both_side()
1916         generate_candidate_address_strings(agent_b.get_local_candidates().await)  in test_agent_restart_both_side()
1920     agent_b.close().await?;  in test_agent_restart_both_side()