Lines Matching refs:pkt
102 let pkt = match rtcp::packet::unmarshal(&mut b) { in new() localVariable
103 Ok(pkt) => pkt, in new()
110 let _ = rtcp_in_modified_tx.send(Ok(pkt)).await; in new()
135 let pkt = match rtp::packet::Packet::unmarshal(&mut b) { in new() localVariable
136 Ok(pkt) => pkt, in new()
143 let _ = rtp_in_modified_tx.send(Ok(pkt)).await; in new()
153 pkt: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write_rtcp()
158 writer.write(pkt, &a).await in write_rtcp()
165 pub async fn write_rtp(&self, pkt: &rtp::packet::Packet) -> Result<usize> { in write_rtp()
169 writer.write(pkt, &a).await in write_rtp()
184 pub async fn receive_rtp(&self, pkt: rtp::packet::Packet) { in receive_rtp()
187 let _ = tx.send(pkt).await; in receive_rtp()
281 async fn write(&self, pkt: &rtp::packet::Packet, _a: &Attributes) -> Result<usize> { in write()
282 let _ = self.rtp_out_modified_tx.send(pkt.clone()).await; in write()
290 let pkt = { in read() localVariable
295 let marshaled = pkt.marshal()?; in read()