168     let (conn_a, conn_b, agent_a, agent_b) = pipe(None, None).await?;  in test_agent_get_stats()
169     assert_eq!(agent_a.get_bytes_received(), 0);  in test_agent_get_stats()
170     assert_eq!(agent_a.get_bytes_sent(), 0);  in test_agent_get_stats()
178     assert_eq!(agent_a.get_bytes_received(), 0);  in test_agent_get_stats()
179     assert_eq!(agent_a.get_bytes_sent(), 10);  in test_agent_get_stats()
1740     let agent_a = Arc::clone(&a_agent);  in test_connection_state_connecting_to_failed()  localVariable
1743         let result = agent_a  in test_connection_state_connecting_to_failed()
1809     let (_, _, agent_a, agent_b) = pipe(  in test_agent_restart_one_side()
1835     agent_a.restart("".to_owned(), "".to_owned()).await?;  in test_agent_restart_one_side()
1839     agent_a.close().await?;  in test_agent_restart_one_side()
1867     let (_, _, agent_a, agent_b) = pipe(  in test_agent_restart_both_side()
1882         generate_candidate_address_strings(agent_a.get_local_candidates().await);  in test_agent_restart_both_side()
1887     agent_a.on_connection_state_change(a_notifier);  in test_agent_restart_both_side()
1893     agent_a.restart("".to_owned(), "".to_owned()).await?;  in test_agent_restart_both_side()
1898     agent_a.set_remote_credentials(ufrag, pwd).await?;  in test_agent_restart_both_side()
1900     let (ufrag, pwd) = agent_a.get_local_user_credentials().await;  in test_agent_restart_both_side()
1903     gather_and_exchange_candidates(&agent_a, &agent_b).await?;  in test_agent_restart_both_side()
1912         generate_candidate_address_strings(agent_a.get_local_candidates().await)  in test_agent_restart_both_side()
1919     agent_a.close().await?;  in test_agent_restart_both_side()