Searched refs:written_rtp (Results 1 – 3 of 3) sorted by relevance
38 let p = timeout_or_fail(Duration::from_millis(10), stream.written_rtp()) in test_responder_interceptor()59 if let Ok(r) = tokio::time::timeout(Duration::from_millis(50), stream.written_rtp()).await { in test_responder_interceptor()70 let result = tokio::time::timeout(Duration::from_millis(10), stream.written_rtp()).await; in test_responder_interceptor()
56 p = stream.written_rtp() =>{ in test_twcc_sender_interceptor()
214 pub async fn written_rtp(&self) -> Option<rtp::packet::Packet> { in written_rtp() method329 timeout_or_fail(Duration::from_millis(10), s.written_rtp()).await; in test_mock_stream()330 let result = tokio::time::timeout(Duration::from_millis(10), s.written_rtp()).await; in test_mock_stream()