Searched refs:read_stream (Results 1 – 2 of 2) sorted by relevance
96 let read_stream = sb.accept().await?; in test_session_srtp_accept() localVariable97 let ssrc = read_stream.get_ssrc(); in test_session_srtp_accept()103 read_stream.read(&mut read_buffer).await?; in test_session_srtp_accept()134 let read_stream = sb.open(TEST_SSRC).await; in test_session_srtp_listen() localVariable138 read_stream.read(&mut read_buffer).await?; in test_session_srtp_listen()164 let read_stream = sb.open(*ssrc).await; in test_session_srtp_multi_ssrc() localVariable165 read_streams.insert(*ssrc, read_stream); in test_session_srtp_multi_ssrc()178 if let Some(read_stream) = read_streams.get_mut(ssrc) { in test_session_srtp_multi_ssrc()179 read_stream.read(&mut read_buffer).await?; in test_session_srtp_multi_ssrc()206 read_stream: &Arc<Stream>, in payload_srtp()[all …]
87 let read_stream = sb.accept().await?; in test_session_srtcp_accept() localVariable88 let ssrc = read_stream.get_ssrc(); in test_session_srtcp_accept()96 read_stream.read(&mut read_buffer).await?; in test_session_srtcp_accept()122 let read_stream = sb.open(TEST_SSRC).await; in test_session_srtcp_listen() localVariable128 read_stream.read(&mut read_buffer).await?; in test_session_srtcp_listen()155 async fn get_sender_ssrc(read_stream: &Arc<Stream>) -> Result<u32> { in get_sender_ssrc()161 let (n, _) = read_stream.read_rtcp(&mut read_buffer).await?; in get_sender_ssrc()172 let read_stream = sb.open(TEST_SSRC).await; in test_session_srtcp_replay_protection() localVariable202 match get_sender_ssrc(&read_stream).await { in test_session_srtcp_replay_protection()