Home
last modified time | relevance | path

Searched refs:data_channel (Results 1 – 22 of 22) sorted by relevance

/webrtc/webrtc/src/data_channel/
H A Dmod.rs84 pub(crate) data_channel: Mutex<Option<Arc<data::data_channel::DataChannel>>>, field
266 let mut data_channel = self.data_channel.lock().await; in handle_open() localVariable
301 data_channel: Arc<data::data_channel::DataChannel>, in read_loop()
370 let data_channel = self.data_channel.lock().await; in send() localVariable
382 let data_channel = self.data_channel.lock().await; in send_text() localVariable
411 let data_channel = self.data_channel.lock().await; in detach() localVariable
431 let data_channel = self.data_channel.lock().await; in close() localVariable
502 let data_channel = self.data_channel.lock().await; in buffered_amount() localVariable
517 let data_channel = self.data_channel.lock().await; in buffered_amount_low_threshold() localVariable
530 let data_channel = self.data_channel.lock().await; in set_buffered_amount_low_threshold() localVariable
[all …]
H A Ddata_channel_test.rs7 use crate::data_channel::data_channel_init::RTCDataChannelInit;
/webrtc/data/src/data_channel/
H A Dmod.rs149 Ok(data_channel) in server()
420 data_channel, in new()
430 self.data_channel in into_inner()
435 self.data_channel.clone() in clone_inner()
495 let data_channel = self.data_channel.clone(); in poll_read() localVariable
566 let data_channel = self.data_channel.clone(); in poll_write() localVariable
577 let data_channel = self.data_channel.clone(); in poll_write() localVariable
585 let data_channel = self.data_channel.clone(); in poll_write() localVariable
638 let data_channel = self.data_channel.clone(); in poll_shutdown() localVariable
640 data_channel in poll_shutdown()
[all …]
/webrtc/examples/examples/data-channels-create/
H A Ddata-channels-create.rs9 use webrtc::data_channel::data_channel_message::DataChannelMessage;
98 let data_channel = peer_connection.create_data_channel("data", None).await?; in main() localVariable
119 let d1 = Arc::clone(&data_channel); in main()
120 data_channel.on_open(Box::new(move || { in main()
142 let d_label = data_channel.label().to_owned(); in main()
143 data_channel.on_message(Box::new(move |msg: DataChannelMessage| { in main()
/webrtc/examples/examples/data-channels-detach-create/
H A Ddata-channels-detach-create.rs110 let data_channel = peer_connection.create_data_channel("data", None).await?; in main() localVariable
131 let d = Arc::clone(&data_channel); in main()
132 data_channel.on_open(Box::new(move || { in main()
205 async fn read_loop(d: Arc<webrtc::data::data_channel::DataChannel>) -> Result<()> { in read_loop()
224 async fn write_loop(d: Arc<webrtc::data::data_channel::DataChannel>) -> Result<()> { in write_loop()
/webrtc/webrtc/src/sctp_transport/
H A Dmod.rs11 use crate::data_channel::data_channel_state::RTCDataChannelState;
12 use crate::data_channel::RTCDataChannel;
24 use crate::data_channel::data_channel_parameters::DataChannelParameters;
27 use data::data_channel::DataChannel;
219 if let Some(dc) = dc.data_channel.lock().await.clone() { in accept_data_channels()
230 data::data_channel::Config::default(), in accept_data_channels()
375 for data_channel in &*data_channels { in collect_stats()
376 match data_channel.ready_state() { in collect_stats()
381 data_channel.collect_stats(collector).await; in collect_stats()
/webrtc/webrtc/src/stats/
H A Dmod.rs1 use crate::data_channel::data_channel_state::RTCDataChannelState;
2 use crate::data_channel::RTCDataChannel;
371 pub(crate) async fn from(data_channel: &RTCDataChannel) -> Self { in from()
372 let state = data_channel.ready_state(); in from()
379 let lock = data_channel.data_channel.lock().await; in from()
391 data_channel_identifier: data_channel.id(), // TODO: "The value is initially null" in from()
392 id: data_channel.stats_id.clone(), in from()
393 label: data_channel.label.clone(), in from()
396 protocol: data_channel.protocol.clone(), in from()
/webrtc/data/src/
H A Dlib.rs4 pub mod data_channel; module
/webrtc/examples/examples/offer-answer/
H A Doffer.rs14 use webrtc::data_channel::data_channel_message::DataChannelMessage;
280 let data_channel = peer_connection.create_data_channel("data", None).await?; in main() localVariable
301 let d1 = Arc::clone(&data_channel); in main()
302 data_channel.on_open(Box::new(move || { in main()
324 let d_label = data_channel.label().to_owned(); in main()
325 data_channel.on_message(Box::new(move |msg: DataChannelMessage| { in main()
H A Danswer.rs14 use webrtc::data_channel::data_channel_message::DataChannelMessage;
15 use webrtc::data_channel::RTCDataChannel;
/webrtc/webrtc/src/
H A Dlib.rs21 pub mod data_channel; module
/webrtc/examples/examples/data-channels-detach/
H A Ddata-channels-detach.rs11 use webrtc::data_channel::RTCDataChannel;
213 async fn read_loop(d: Arc<webrtc::data::data_channel::DataChannel>) -> Result<()> { in read_loop()
232 async fn write_loop(d: Arc<webrtc::data::data_channel::DataChannel>) -> Result<()> { in write_loop()
/webrtc/examples/examples/ortc/
H A Dortc.rs9 use webrtc::data_channel::data_channel_message::DataChannelMessage;
10 use webrtc::data_channel::data_channel_parameters::DataChannelParameters;
11 use webrtc::data_channel::RTCDataChannel;
/webrtc/webrtc/src/api/
H A Dmod.rs17 use crate::data_channel::data_channel_parameters::DataChannelParameters;
18 use crate::data_channel::RTCDataChannel;
/webrtc/examples/examples/data-channels/
H A Ddata-channels.rs9 use webrtc::data_channel::data_channel_message::DataChannelMessage;
10 use webrtc::data_channel::RTCDataChannel;
/webrtc/examples/examples/data-channels-close/
H A Ddata-channels-close.rs11 use webrtc::data_channel::data_channel_message::DataChannelMessage;
12 use webrtc::data_channel::RTCDataChannel;
/webrtc/data/
H A DCHANGELOG.md5 * Remove builder pattern from `data_channel::Config` [#411](https://github.com/webrtc-rs/webrtc/pul…
/webrtc/webrtc/src/dtls_transport/
H A Ddtls_transport_test.rs4 use crate::data_channel::RTCDataChannel;
/webrtc/examples/examples/data-channels-flow-control/
H A Ddata-channels-flow-control.rs15 data_channel::data_channel_init::RTCDataChannelInit,
/webrtc/examples/examples/ice-restart/
H A Dice-restart.rs15 use webrtc::data_channel::RTCDataChannel;
/webrtc/webrtc/src/peer_connection/
H A Dmod.rs17 use crate::data_channel::data_channel_init::RTCDataChannelInit;
18 use crate::data_channel::data_channel_parameters::DataChannelParameters;
19 use crate::data_channel::data_channel_state::RTCDataChannelState;
20 use crate::data_channel::RTCDataChannel;
/webrtc/webrtc/
H A DCHANGELOG.md175 * [#205 data_channel: handle stream EOF](https://github.com/webrtc-rs/webrtc/pull/205) contributed …