Searched defs:Stream (Results 1 – 11 of 11) sorted by relevance
| /webrtc/srtp/src/ |
| H A D | stream.rs | 14 pub struct Stream { struct
21 impl Stream { implementation
|
| /webrtc/sctp/src/stream/ |
| H A D | mod.rs | 67 pub struct Stream { struct
90 impl fmt::Debug for Stream { argument
113 impl Stream { impl
618 pub fn into_inner(self) -> Arc<Stream> { in into_inner()
624 pub fn clone_inner(&self) -> Arc<Stream> { in clone_inner()
852 fn as_ref(&self) -> &Stream { in as_ref()
|
| /webrtc/interceptor/src/ |
| H A D | stream_reader.rs | 8 impl RTPReader for Stream { implementation
15 impl RTCPReader for Stream { implementation
|
| /webrtc/srtp/src/session/ |
| H A D | mod.rs | 124 async fn close_stream(streams_map: &Arc<Mutex<HashMap<u32, Arc<Stream>>>>, ssrc: u32) { in close_stream()
132 streams_map: &Arc<Mutex<HashMap<u32, Arc<Stream>>>>, in incoming()
134 new_stream_tx: &mut mpsc::Sender<Arc<Stream>>, in incoming()
185 streams_map: &Arc<Mutex<HashMap<u32, Arc<Stream>>>>, in get_or_create_stream()
189 ) -> (Arc<Stream>, bool) { in get_or_create_stream()
203 pub async fn open(&self, ssrc: u32) -> Arc<Stream> { in open()
216 pub async fn accept(&self) -> Result<Arc<Stream>> { in accept()
|
| H A D | session_rtp_test.rs | 206 read_stream: &Arc<Stream>, in payload_srtp()
|
| /webrtc/webrtc/src/dtls_transport/ |
| H A D | mod.rs | 569 pub(crate) async fn store_simulcast_stream(&self, ssrc: SSRC, stream: Arc<Stream>) { in store_simulcast_stream()
585 Arc<srtp::stream::Stream>, in streams_for_ssrc()
|
| /webrtc/data/src/data_channel/ |
| H A D | mod.rs | 53 pub fn new(stream: Arc<Stream>, config: Config) -> Self { in new()
103 pub async fn client(stream: Arc<Stream>, config: Config) -> Result<Self> { in client()
122 pub async fn server(stream: Arc<Stream>, mut config: Config) -> Result<Self> { in server()
|
| /webrtc/sctp/src/association/ |
| H A D | mod.rs | 579 ) -> Result<Arc<Stream>> { in open_stream()
585 pub async fn accept_stream(&self) -> Option<Arc<Stream>> { in accept_stream()
|
| H A D | association_internal.rs | 98 accept_ch_tx: mpsc::Sender<Arc<Stream>>, in new()
1021 ) -> Result<Arc<Stream>> { in open_stream()
1035 fn create_stream(&mut self, stream_identifier: u16, accept: bool) -> Option<Arc<Stream>> { in create_stream()
1071 fn get_or_create_stream(&mut self, stream_identifier: u16) -> Option<Arc<Stream>> { in get_or_create_stream()
|
| H A D | association_test.rs | 186 ) -> Result<(Arc<Stream>, Arc<Stream>)> { in establish_session_pair()
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_internal.rs | 903 rtp_stream: Arc<Stream>, in handle_incoming_ssrc()
|