Searched refs:written_rtcp (Results 1 – 5 of 5) sorted by relevance
51 let _ = stream.written_rtcp().await; in test_generator_interceptor()53 let r = timeout_or_fail(Duration::from_millis(10), stream.written_rtcp()) in test_generator_interceptor()
31 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_before_any_packet()95 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_after_rtp_packets()178 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_after_rtp_and_rtcp_packets()252 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_overflow()356 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_overflow_five_pkts()428 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_packet_loss()469 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_packet_loss()539 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_overflow_and_packet_loss()601 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_reordered_packets()746 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_delay()
33 pkts = stream.written_rtcp() => { in test_twcc_receiver_interceptor_before_any_packets()80 let pkts = stream.written_rtcp().await.unwrap(); in test_twcc_receiver_interceptor_after_rtp_packets()147 let pkts = stream.written_rtcp().await.unwrap(); in test_twcc_receiver_interceptor_different_delays_between_rtp_packets()226 let pkts = stream.written_rtcp().await.unwrap(); in test_twcc_receiver_interceptor_packet_loss()315 let pkts = stream.written_rtcp().await.unwrap(); in test_twcc_receiver_interceptor_overflow()
34 let pkts = stream.written_rtcp().await.unwrap(); in test_sender_interceptor_before_any_packet()98 let pkts = stream.written_rtcp().await.unwrap(); in test_sender_interceptor_after_rtp_packets()200 let pkts = stream.written_rtcp().await.unwrap(); in test_sender_interceptor_after_rtp_packets_overflow()
192 pub async fn written_rtcp(&self) -> Option<Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>> { in written_rtcp() method321 timeout_or_fail(Duration::from_millis(10), s.written_rtcp()).await; in test_mock_stream()322 let result = tokio::time::timeout(Duration::from_millis(10), s.written_rtcp()).await; in test_mock_stream()