Searched refs:c2 (Results 1 – 5 of 5) sorted by relevance
6 let (c1, c2) = pipe(); in test_pipe()12 let n = c2.recv(&mut b2).await?; in test_pipe()16 let n = c2.send(&b2[..10]).await?; in test_pipe()18 let n = c2.send(&b2[..5]).await?; in test_pipe()
29 let mut c2 = AttrControlled::default(); in test_controlled_get_from() localVariable30 let result = c2.get_from(&m3); in test_controlled_get_from()66 let mut c2 = AttrControlling::default(); in test_controlling_get_from() localVariable67 let result = c2.get_from(&m3); in test_controlling_get_from()119 let mut c2 = AttrControl::default(); in test_control_get_from() localVariable120 let result = c2.get_from(&m3); in test_control_get_from()157 let mut c2 = AttrControl::default(); in test_control_get_from() localVariable158 let result = c2.get_from(&m3); in test_control_get_from()
78 let c2 = c1.clone(); in test_client_with_stun_send_binding_request_to_parallel() localVariable87 if let Ok(resp) = c2.send_binding_request_to(&to.to_string()).await { in test_client_with_stun_send_binding_request_to_parallel()
122 let c2 = ChannelBind::new(ChannelNumber(MIN_CHANNEL_NUMBER + 1), addr); in test_add_channel_bind() localVariable123 let result = a.add_channel_bind(c2, DEFAULT_LIFETIME).await; in test_add_channel_bind()
394 let c2: Arc<dyn Candidate + Send + Sync> = in gather_and_exchange_candidates() localVariable396 b_agent.add_remote_candidate(&c2)?; in gather_and_exchange_candidates()401 let c2: Arc<dyn Candidate + Send + Sync> = in gather_and_exchange_candidates() localVariable403 a_agent.add_remote_candidate(&c2)?; in gather_and_exchange_candidates()