Lines Matching refs:data_channel
144 let data_channel = DataChannel::new(stream, config); in server() localVariable
146 data_channel.write_data_channel_ack().await?; in server()
147 data_channel.commit_reliability_params(); in server()
149 Ok(data_channel) in server()
396 data_channel: Arc<DataChannel>, field
418 pub fn new(data_channel: Arc<DataChannel>) -> Self { in new()
420 data_channel, in new()
430 self.data_channel in into_inner()
435 self.data_channel.clone() in clone_inner()
440 self.data_channel.messages_sent() in messages_sent()
445 self.data_channel.messages_received() in messages_received()
450 self.data_channel.bytes_sent() in bytes_sent()
455 self.data_channel.bytes_received() in bytes_received()
460 self.data_channel.stream_identifier() in stream_identifier()
466 self.data_channel.buffered_amount() in buffered_amount()
472 self.data_channel.buffered_amount_low_threshold() in buffered_amount_low_threshold()
495 let data_channel = self.data_channel.clone(); in poll_read() localVariable
498 data_channel.read(temp_buf.as_mut_slice()).await.map(|n| { in poll_read()
566 let data_channel = self.data_channel.clone(); in poll_write() localVariable
569 Some(Box::pin(async move { data_channel.write(&bytes).await })); in poll_write()
577 let data_channel = self.data_channel.clone(); in poll_write() localVariable
580 Some(Box::pin(async move { data_channel.write(&bytes).await })); in poll_write()
585 let data_channel = self.data_channel.clone(); in poll_write() localVariable
589 .insert(Box::pin(async move { data_channel.write(&bytes).await })); in poll_write()
638 let data_channel = self.data_channel.clone(); in poll_shutdown() localVariable
640 data_channel in poll_shutdown()
672 .field("data_channel", &self.data_channel) in fmt()
680 &self.data_channel in as_ref()