Lines Matching refs:stream
21 let stream = MockStream::new( in test_receiver_interceptor_before_any_packet() localVariable
31 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_before_any_packet()
55 stream.close().await?; in test_receiver_interceptor_before_any_packet()
73 let stream = MockStream::new( in test_receiver_interceptor_after_rtp_packets() localVariable
84 stream in test_receiver_interceptor_after_rtp_packets()
95 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_after_rtp_packets()
118 stream.close().await?; in test_receiver_interceptor_after_rtp_packets()
138 let stream = MockStream::new( in test_receiver_interceptor_after_rtp_and_rtcp_packets() localVariable
149 stream in test_receiver_interceptor_after_rtp_and_rtcp_packets()
167 stream in test_receiver_interceptor_after_rtp_and_rtcp_packets()
178 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_after_rtp_and_rtcp_packets()
201 stream.close().await?; in test_receiver_interceptor_after_rtp_and_rtcp_packets()
222 let stream = MockStream::new( in test_receiver_interceptor_overflow() localVariable
232 stream in test_receiver_interceptor_overflow()
242 stream in test_receiver_interceptor_overflow()
252 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_overflow()
279 stream.close().await?; in test_receiver_interceptor_overflow()
296 let stream = MockStream::new( in test_receiver_interceptor_overflow_five_pkts() localVariable
306 stream in test_receiver_interceptor_overflow_five_pkts()
316 stream in test_receiver_interceptor_overflow_five_pkts()
326 stream in test_receiver_interceptor_overflow_five_pkts()
336 stream in test_receiver_interceptor_overflow_five_pkts()
346 stream in test_receiver_interceptor_overflow_five_pkts()
356 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_overflow_five_pkts()
379 stream.close().await?; in test_receiver_interceptor_overflow_five_pkts()
398 let stream = MockStream::new( in test_receiver_interceptor_packet_loss() localVariable
408 stream in test_receiver_interceptor_packet_loss()
418 stream in test_receiver_interceptor_packet_loss()
428 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_packet_loss()
458 stream in test_receiver_interceptor_packet_loss()
469 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_packet_loss()
492 stream.close().await?; in test_receiver_interceptor_packet_loss()
509 let stream = MockStream::new( in test_receiver_interceptor_overflow_and_packet_loss() localVariable
519 stream in test_receiver_interceptor_overflow_and_packet_loss()
529 stream in test_receiver_interceptor_overflow_and_packet_loss()
539 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_overflow_and_packet_loss()
562 stream.close().await?; in test_receiver_interceptor_overflow_and_packet_loss()
579 let stream = MockStream::new( in test_receiver_interceptor_reordered_packets() localVariable
590 stream in test_receiver_interceptor_reordered_packets()
601 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_reordered_packets()
624 stream.close().await?; in test_receiver_interceptor_reordered_packets()
641 let stream = MockStream::new( in test_receiver_interceptor_jitter() localVariable
652 stream in test_receiver_interceptor_jitter()
662 stream.read_rtp().await; in test_receiver_interceptor_jitter()
665 stream in test_receiver_interceptor_jitter()
681 let pkts = stream.last_written_rtcp().await.unwrap(); in test_receiver_interceptor_jitter()
704 stream.close().await?; in test_receiver_interceptor_jitter()
721 let stream = MockStream::new( in test_receiver_interceptor_delay() localVariable
732 stream in test_receiver_interceptor_delay()
742 stream.read_rtcp().await; in test_receiver_interceptor_delay()
746 let pkts = stream.written_rtcp().await.unwrap(); in test_receiver_interceptor_delay()
769 stream.close().await?; in test_receiver_interceptor_delay()