| /webrtc/interceptor/src/ |
| H A D | stream_reader.rs | 5 use srtp::stream::Stream;
8 impl RTPReader for Stream { implementation
15 impl RTCPReader for Stream { implementation
|
| /webrtc/srtp/src/session/ |
| H A D | mod.rs | 33 streams_map: Arc<Mutex<HashMap<u32, Arc<Stream>>>>,
34 new_stream_rx: Arc<Mutex<mpsc::Receiver<Arc<Stream>>>>,
124 async fn close_stream(streams_map: &Arc<Mutex<HashMap<u32, Arc<Stream>>>>, ssrc: u32) { in close_stream() argument
132 streams_map: &Arc<Mutex<HashMap<u32, Arc<Stream>>>>, in incoming() argument
134 new_stream_tx: &mut mpsc::Sender<Arc<Stream>>, in incoming() argument
185 streams_map: &Arc<Mutex<HashMap<u32, Arc<Stream>>>>, in get_or_create_stream() argument
189 ) -> (Arc<Stream>, bool) { in get_or_create_stream() argument
195 let stream = Arc::new(Stream::new(ssrc, close_stream_tx, is_rtp)); in get_or_create_stream()
203 pub async fn open(&self, ssrc: u32) -> Arc<Stream> { in open() argument
216 pub async fn accept(&self) -> Result<Arc<Stream>> { in accept() argument
|
| H A D | session_rtcp_test.rs | 155 async fn get_sender_ssrc(read_stream: &Arc<Stream>) -> Result<u32> { in get_sender_ssrc()
|
| H A D | session_rtp_test.rs | 206 read_stream: &Arc<Stream>, in payload_srtp() argument
|
| /webrtc/sctp/ |
| H A D | CHANGELOG.md | 15 * Make `sctp::Stream::write` & `sctp::Stream::write_sctp` async again [#367](https://github.com/web…
27 * Make `Stream::on_buffered_amount_low` function non-async [#338](https://github.com/webrtc-rs/webr…
28 * Make `sctp::Stream::write` & `sctp::Stream::write_sctp` sync [#344](https://github.com/webrtc-rs/…
|
| /webrtc/srtp/src/ |
| H A D | stream.rs | 14 pub struct Stream { struct
21 impl Stream { implementation
24 Stream { in new()
|
| /webrtc/webrtc/src/track/ |
| H A D | mod.rs | 16 pub(crate) rtp_read_stream: Option<Arc<srtp::stream::Stream>>,
18 pub(crate) rtcp_read_stream: Option<Arc<srtp::stream::Stream>>,
|
| /webrtc/sctp/src/stream/ |
| H A D | stream_test.rs | 9 let s = Stream::default(); in test_stream_buffered_amount()
28 let s = Stream::default(); in test_stream_amount_on_buffered_amount_low()
76 let s = Stream::new( in test_stream()
150 let s = Arc::new(Stream::new( in test_poll_stream()
|
| H A D | mod.rs | 67 pub struct Stream { struct
90 impl fmt::Debug for Stream { argument
113 impl Stream { impl
123 Stream { in new()
585 stream: Arc<Stream>,
606 pub fn new(stream: Arc<Stream>) -> Self { in new()
618 pub fn into_inner(self) -> Arc<Stream> { in into_inner() argument
624 pub fn clone_inner(&self) -> Arc<Stream> { in clone_inner() argument
851 impl AsRef<Stream> for PollStream {
852 fn as_ref(&self) -> &Stream { in as_ref() argument
|
| /webrtc/webrtc/src/dtls_transport/ |
| H A D | mod.rs | 17 use srtp::stream::Stream;
79 pub(crate) simulcast_streams: Mutex<HashMap<SSRC, Arc<Stream>>>,
505 let simulcast_streams: Vec<Arc<Stream>> = { in stop()
569 pub(crate) async fn store_simulcast_stream(&self, ssrc: SSRC, stream: Arc<Stream>) { in store_simulcast_stream() argument
585 Arc<srtp::stream::Stream>, in streams_for_ssrc() argument
587 Arc<srtp::stream::Stream>, in streams_for_ssrc()
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | srtp_writer_future.rs | 7 use srtp::stream::Stream;
109 pub(crate) rtcp_read_stream: Mutex<Option<Arc<Stream>>>, // atomic.Value // *
|
| /webrtc/data/src/data_channel/ |
| H A D | mod.rs | 43 stream: Arc<Stream>,
53 pub fn new(stream: Arc<Stream>, config: Config) -> Self { in new() argument
103 pub async fn client(stream: Arc<Stream>, config: Config) -> Result<Self> { in client() argument
122 pub async fn server(stream: Arc<Stream>, mut config: Config) -> Result<Self> { in server() argument
|
| /webrtc/sctp/src/association/ |
| H A D | mod.rs | 207 accept_ch_rx: Mutex<mpsc::Receiver<Arc<Stream>>>,
579 ) -> Result<Arc<Stream>> { in open_stream() argument
585 pub async fn accept_stream(&self) -> Option<Arc<Stream>> { in accept_stream() argument
|
| H A D | association_internal.rs | 76 streams: HashMap<u16, Arc<Stream>>,
79 accept_ch_tx: Option<mpsc::Sender<Arc<Stream>>>,
98 accept_ch_tx: mpsc::Sender<Arc<Stream>>, in new() argument
1021 ) -> Result<Arc<Stream>> { in open_stream() argument
1035 fn create_stream(&mut self, stream_identifier: u16, accept: bool) -> Option<Arc<Stream>> { in create_stream() argument
1036 let s = Arc::new(Stream::new( in create_stream()
1071 fn get_or_create_stream(&mut self, stream_identifier: u16) -> Option<Arc<Stream>> { in get_or_create_stream() argument
|
| H A D | association_test.rs | 186 ) -> Result<(Arc<Stream>, Arc<Stream>)> { in establish_session_pair() argument
|
| /webrtc/ |
| H A D | README.md | 46 …/wp-content/uploads/f7401112f41742c4e173c30d4f318cb8/stream_logo_white.png?h=50" alt="Stream Chat">
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_internal.rs | 903 rtp_stream: Arc<Stream>, in handle_incoming_ssrc() argument
|
| H A D | mod.rs | 80 use srtp::stream::Stream;
|