Searched refs:read_rtcp (Results 1 – 9 of 9) sorted by relevance
69 pub async fn read_rtcp(&self, buf: &mut [u8]) -> Result<(usize, rtcp::header::Header)> { in read_rtcp() method
220 pub async fn read_rtcp( in read_rtcp() method339 timeout_or_fail(Duration::from_millis(10), s.read_rtcp()) in test_mock_stream()344 let result = tokio::time::timeout(Duration::from_millis(10), s.read_rtcp()).await; in test_mock_stream()
67 async fn read_rtcp( in read_rtcp() method477 pub async fn read_rtcp( in read_rtcp() method480 self.internal.read_rtcp(self.receive_mtu).await in read_rtcp()
181 let result = tokio::time::timeout(Duration::from_secs(1), rtp_sender.read_rtcp()).await; in test_rtp_sender_set_read_deadline()
161 let (n, _) = read_stream.read_rtcp(&mut read_buffer).await?; in get_sender_ssrc()
226 async fn read_rtcp( in read_rtcp() method627 pub async fn read_rtcp( in read_rtcp() method630 self.internal.read_rtcp(self.receive_mtu).await in read_rtcp()
193 let result = tokio::time::timeout(Duration::from_secs(1), receiver.read_rtcp()).await; in test_rtp_receiver_set_read_deadline()
1052 .read_rtcp() in test_stats_interceptor_rtcp()1149 let _ = recv_stream.read_rtcp().await.expect("read_rtcp failed"); in test_stats_interceptor_rtcp()
742 stream.read_rtcp().await; in test_receiver_interceptor_delay()