Searched refs:RtpPacket (Results 1 – 8 of 8) sorted by relevance
22 pub struct RtpPacket { struct31 impl Unmarshal<&mut BytesReader, Result<Self, BytesReadError>> for RtpPacket { argument37 let mut rtp_packet = RtpPacket { in unmarshal()71 impl Marshal<Result<BytesMut, BytesWriteError>> for RtpPacket { implementation93 impl RtpPacket { implementation
12 use super::RtpPacket;60 let mut packet = RtpPacket::new(self.header.clone()); in pack()119 let rtp_packet = RtpPacket::unmarshal(reader)?; in unpack()
4 use super::RtpPacket;33 RtpPacket,40 Box<dyn Fn(RtpPacket) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>> + Send + Sync>;
14 use super::RtpPacket;100 let mut packet = RtpPacket::new(self.header.clone()); in pack_fu()124 let mut packet = RtpPacket::new(self.header.clone()); in pack_single()183 let rtp_packet = RtpPacket::unmarshal(reader)?; in unpack()
14 use super::RtpPacket;75 let mut packet = RtpPacket::new(self.header.clone()); in pack_fu_a()102 let mut packet = RtpPacket::new(self.header.clone()); in pack_single()164 let rtp_packet = RtpPacket::unmarshal(reader)?; in unpack()
2 use crate::rtp::RtpPacket;215 pub fn send_rtp(&mut self, pkt: RtpPacket) { in send_rtp() argument228 pub fn received_rtp(&mut self, pkt: RtpPacket) { in received_rtp() argument
9 use crate::rtp::RtpPacket;189 pub fn on_packet(&mut self, packet: RtpPacket) { in on_packet() argument
10 use crate::rtp::RtpPacket;311 rtp_channel_guard.on_packet_for_rtcp_handler(Box::new(move |packet: RtpPacket| { in handle_announce()428 move |io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, packet: RtpPacket| { in handle_play()444 move |io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, packet: RtpPacket| { in handle_play()