Lines Matching refs:packet

10 type RTCPPackets = Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>;
20 rtp_out_modified_tx: mpsc::Sender<rtp::packet::Packet>,
22 rtp_in_rx: Mutex<mpsc::Receiver<rtp::packet::Packet>>,
25 rtp_out_modified_rx: Mutex<mpsc::Receiver<rtp::packet::Packet>>,
27 rtp_in_tx: Mutex<Option<mpsc::Sender<rtp::packet::Packet>>>,
30 rtp_in_modified_rx: Mutex<mpsc::Receiver<Result<rtp::packet::Packet>>>,
102 let pkt = match rtcp::packet::unmarshal(&mut b) { in new()
135 let pkt = match rtp::packet::Packet::unmarshal(&mut b) { in new()
153 pkt: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write_rtcp()
165 pub async fn write_rtp(&self, pkt: &rtp::packet::Packet) -> Result<usize> { in write_rtp()
176 pub async fn receive_rtcp(&self, pkts: Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>) { in receive_rtcp()
184 pub async fn receive_rtp(&self, pkt: rtp::packet::Packet) { in receive_rtp()
192 pub async fn written_rtcp(&self) -> Option<Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>> { in written_rtcp()
202 ) -> Option<Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>> { in last_written_rtcp()
214 pub async fn written_rtp(&self) -> Option<rtp::packet::Packet> { in written_rtp()
222 ) -> Option<Result<Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>>> { in read_rtcp()
228 pub async fn read_rtp(&self) -> Option<Result<rtp::packet::Packet>> { in read_rtp()
251 pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write()
268 let marshaled = rtcp::packet::marshal(&pkts)?; in read()
281 async fn write(&self, pkt: &rtp::packet::Packet, _a: &Attributes) -> Result<usize> { in write()
328 s.write_rtp(&rtp::packet::Packet::default()).await?; in test_mock_stream()
350 s.receive_rtp(rtp::packet::Packet::default()).await; in test_mock_stream()