refactor

Author: rogurotus

srtp/src/stream.rs

@@ -60,8 +60,8 @@ impl Stream {
 
         let n = self.buffer.read(buf, None).await?;
         let mut b = &buf[..n];
-
         let pkt = rtp::packet::Packet::unmarshal(&mut b)?;
+
         Ok(pkt)
     }
 

webrtc/src/peer_connection/peer_connection_internal.rs

@@ -956,8 +956,7 @@ impl PeerConnectionInternal {
             rsid_extension_id as u8,
         )?;
 
-        let mut packet_buf = &buf.as_mut_slice()[..self.setting_engine.get_receive_mtu()];
-        let packet = rtp::packet::Packet::unmarshal(&mut packet_buf).unwrap();
+        let packet = rtp::packet::Packet::unmarshal(&mut buf.as_slice()).unwrap();
 
         // TODO: Can we have attributes on the first packets?
         buffered_packets.push_back((packet, Attributes::new()));

webrtc/src/rtp_transceiver/srtp_writer_future.rs

@@ -266,9 +266,8 @@ impl RTCPReader for SrtpWriterFuture {
         a: &Attributes,
     ) -> IResult<(Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>, Attributes)> {
         let read = self.read(buf).await?;
-        let mut b = &buf[..read];
+        let pkt = rtcp::packet::unmarshal(&mut &buf[..read])?;
 
-        let pkt = rtcp::packet::unmarshal(&mut b)?;
         Ok((pkt, a.clone()))
     }
 }