Lines Matching refs:read_stream
96 let read_stream = sb.accept().await?; in test_session_srtp_accept() localVariable
97 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() localVariable
138 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() localVariable
165 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()
213 let (n, hdr) = read_stream.read_rtp(&mut read_buffer).await?; in payload_srtp()
232 let read_stream = sb.open(TEST_SSRC).await; in test_session_srtp_replay_protection() localVariable
273 let seq = payload_srtp(&read_stream, RTP_HEADER_SIZE, &test_payload) in test_session_srtp_replay_protection()