Searched refs:RTCDataChannel (Results 1 – 17 of 17) sorted by relevance
18 use crate::data_channel::RTCDataChannel;126 ) -> Result<RTCDataChannel> { in new_data_channel() argument132 let d = RTCDataChannel::new(params, Arc::clone(&self.setting_engine)); in new_data_channel()
12 use crate::data_channel::RTCDataChannel;39 dyn (FnMut(Arc<RTCDataChannel>) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>>)45 dyn (FnMut(Arc<RTCDataChannel>) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>>)53 data_channels: Arc<Mutex<Vec<Arc<RTCDataChannel>>>>,89 pub(crate) data_channels: Arc<Mutex<Vec<Arc<RTCDataChannel>>>>,284 let rtc_dc = Arc::new(RTCDataChannel::new( in accept_data_channels()
9 data_channels.push(Arc::new(RTCDataChannel { in test_generate_data_channel_id()
41 Arc<RTCDataChannel>, in set_up_data_channel_parameters_test() argument199 answer_pc.on_data_channel(Box::new(move |d: Arc<RTCDataChannel>| { in test_data_channel_send_before_signaling()255 answer_pc.on_data_channel(Box::new(move |d: Arc<RTCDataChannel>| { in test_data_channel_send_after_connected()386 answer_pc.on_data_channel(Box::new(move |d: Arc<RTCDataChannel>| { in test_data_channel_parameters_max_packet_life_time_exchange()435 answer_pc.on_data_channel(Box::new(move |d: Arc<RTCDataChannel>| { in test_data_channel_parameters_max_retransmits_exchange()596 let dc = RTCDataChannel { in test_data_channel_event_handlers()644 let dc = RTCDataChannel { in test_data_channel_messages_are_ordered()781 let dc = RTCDataChannel { in test_data_channel_parameters_go()1021 pcb.on_data_channel(Box::new(move |dc: Arc<RTCDataChannel>| { in test_eof_detach()1127 pcb.on_data_channel(Box::new(move |dc: Arc<RTCDataChannel>| { in test_eof_no_detach()[all …]
56 pub struct RTCDataChannel { struct92 impl RTCDataChannel { argument98 RTCDataChannel { in new()280 RTCDataChannel::read_loop( in handle_open()
11 use webrtc::data_channel::RTCDataChannel;103 sctp.on_data_channel(Box::new(move |d: Arc<RTCDataChannel>| { in main()259 async fn handle_on_open(d: Arc<RTCDataChannel>) -> Result<()> { in handle_on_open()
10 use webrtc::data_channel::RTCDataChannel;118 .on_data_channel(Box::new(move |d: Arc<RTCDataChannel>| { in main()
4 use crate::data_channel::RTCDataChannel;44 pc_answer.on_data_channel(Box::new(|_: Arc<RTCDataChannel>| { in test_invalid_fingerprint_causes_failed()
11 use webrtc::data_channel::RTCDataChannel;129 peer_connection.on_data_channel(Box::new(move |d: Arc<RTCDataChannel>| { in main()
12 use webrtc::data_channel::RTCDataChannel;134 .on_data_channel(Box::new(move |d: Arc<RTCDataChannel>| { in main()
15 use webrtc::data_channel::RTCDataChannel;120 pc.on_data_channel(Box::new(|d: Arc<RTCDataChannel>| { in do_signaling()
15 use webrtc::data_channel::RTCDataChannel;340 peer_connection.on_data_channel(Box::new(move |d: Arc<RTCDataChannel>| { in main()
11 See <https://developer.mozilla.org/en-US/docs/Web/API/RTCDataChannel> for more details.
2 use crate::data_channel::RTCDataChannel;371 pub(crate) async fn from(data_channel: &RTCDataChannel) -> Self { in from()
20 use crate::data_channel::RTCDataChannel;134 dyn (FnMut(Arc<RTCDataChannel>) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>>)1791 ) -> Result<Arc<RTCDataChannel>> { in create_data_channel() argument1836 let d = Arc::new(RTCDataChannel::new( in create_data_channel()
136 .on_data_channel(Box::new(move |d: Arc<RTCDataChannel>| { in new()
92 - `RTCDataChannel`: