Lines Matching refs:s
317 let s = MockStream::new(&StreamInfo::default(), Arc::new(NoOp)).await; in test_mock_stream() localVariable
319 s.write_rtcp(&[Box::<PictureLossIndication>::default()]) in test_mock_stream()
321 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()
328 s.write_rtp(&rtp::packet::Packet::default()).await?; in test_mock_stream()
329 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()
336 s.receive_rtcp(vec![Box::<PictureLossIndication>::default()]) in test_mock_stream()
339 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()
350 s.receive_rtp(rtp::packet::Packet::default()).await; in test_mock_stream()
352 timeout_or_fail(Duration::from_millis(10), s.read_rtp()) in test_mock_stream()
357 let result = tokio::time::timeout(Duration::from_millis(10), s.read_rtp()).await; in test_mock_stream()
363 s.close().await?; in test_mock_stream()