Lines Matching refs:a_agent
437 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_connectivity_on_startup() localVariable
438 a_agent.on_connection_state_change(a_notifier); in test_connectivity_on_startup()
454 let (a_ufrag, a_pwd) = a_agent.get_local_user_credentials().await; in test_connectivity_on_startup()
457 gather_and_exchange_candidates(&a_agent, &b_agent).await?; in test_connectivity_on_startup()
465 a_agent.on_connection_state_change(Box::new(move |s: ConnectionState| { in test_connectivity_on_startup()
476 let result = a_agent.accept(a_cancel_rx, b_ufrag, b_pwd).await; in test_connectivity_on_startup()
545 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_connectivity_lite() localVariable
546 a_agent.on_connection_state_change(a_notifier); in test_connectivity_lite()
561 let _ = connect_with_vnet(&a_agent, &b_agent).await?; in test_connectivity_lite()
955 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_connection_state_callback() localVariable
970 a_agent.on_connection_state_change(Box::new(move |c: ConnectionState| { in test_connection_state_callback()
1008 connect_with_vnet(&a_agent, &b_agent).await?; in test_connection_state_callback()
1019 a_agent.close().await?; in test_connection_state_callback()
1653 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_connection_state_failed_delete_all_candidates() localVariable
1658 a_agent.on_connection_state_change(Box::new(move |c: ConnectionState| { in test_connection_state_failed_delete_all_candidates()
1668 connect_with_vnet(&a_agent, &b_agent).await?; in test_connection_state_failed_delete_all_candidates()
1673 let remote_candidates = a_agent.internal.remote_candidates.lock().await; in test_connection_state_failed_delete_all_candidates()
1677 let local_candidates = a_agent.internal.local_candidates.lock().await; in test_connection_state_failed_delete_all_candidates()
1682 a_agent.close().await?; in test_connection_state_failed_delete_all_candidates()
1707 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_connection_state_connecting_to_failed() localVariable
1735 a_agent.on_connection_state_change(connection_state_check(wf1, wc1)); in test_connection_state_connecting_to_failed()
1740 let agent_a = Arc::clone(&a_agent); in test_connection_state_connecting_to_failed()
1761 a_agent.close().await?; in test_connection_state_connecting_to_failed()
1975 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_close_in_connection_state_callback() localVariable
1982 a_agent.on_connection_state_change(Box::new(move |c: ConnectionState| { in test_close_in_connection_state_callback()
1996 connect_with_vnet(&a_agent, &b_agent).await?; in test_close_in_connection_state_callback()
1999 a_agent.close().await?; in test_close_in_connection_state_callback()
2032 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_run_task_in_connection_state_callback() localVariable
2037 a_agent.on_connection_state_change(Box::new(move |c: ConnectionState| { in test_run_task_in_connection_state_callback()
2047 connect_with_vnet(&a_agent, &b_agent).await?; in test_run_task_in_connection_state_callback()
2050 let _ = a_agent.get_local_user_credentials().await; in test_run_task_in_connection_state_callback()
2051 a_agent.restart("".to_owned(), "".to_owned()).await?; in test_run_task_in_connection_state_callback()
2053 a_agent.close().await?; in test_run_task_in_connection_state_callback()
2084 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_run_task_in_selected_candidate_pair_change_callback() localVariable
2089 a_agent.on_selected_candidate_pair_change(Box::new( in test_run_task_in_selected_candidate_pair_change_callback()
2101 a_agent.on_connection_state_change(Box::new(move |c: ConnectionState| { in test_run_task_in_selected_candidate_pair_change_callback()
2111 connect_with_vnet(&a_agent, &b_agent).await?; in test_run_task_in_selected_candidate_pair_change_callback()
2116 let _ = a_agent.get_local_user_credentials().await; in test_run_task_in_selected_candidate_pair_change_callback()
2118 a_agent.close().await?; in test_run_task_in_selected_candidate_pair_change_callback()
2129 let a_agent = Arc::new( in test_lite_lifecycle() localVariable
2138 a_agent.on_connection_state_change(a_notifier); in test_lite_lifecycle()
2185 connect_with_vnet(&b_agent, &a_agent).await?; in test_lite_lifecycle()
2189 a_agent.close().await?; in test_lite_lifecycle()