Merge branch 'master' into fix-signaling-state

Author: logist322

media/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "webrtc-media"
-version = "0.5.0"
+version = "0.5.1"
 authors = ["Rain Liu <yliu@webrtc.rs>"]
 edition = "2021"
 description = "A pure Rust implementation of WebRTC Media API"

media/src/io/h264_reader/mod.rs

@@ -154,7 +154,7 @@ impl<R: Read> H264Reader<R> {
         }
     }
 
-    fn read(&mut self, num_to_read: usize) -> Bytes {
+    fn read(&mut self, num_to_read: usize) -> Result<Bytes> {
         let buf = &mut self.temp_buf;
         while self.read_buffer.len() < num_to_read {
             let n = match self.reader.read(buf) {
@@ -164,7 +164,7 @@ impl<R: Read> H264Reader<R> {
                     }
                     n
                 }
-                Err(_) => break,
+                Err(e) => return Err(Error::Io(e.into())),
             };
 
             self.read_buffer.extend_from_slice(&buf[0..n]);
@@ -176,15 +176,15 @@ impl<R: Read> H264Reader<R> {
             self.read_buffer.len()
         };
 
-        Bytes::from(
+        Ok(Bytes::from(
             self.read_buffer
                 .drain(..num_should_read)
                 .collect::<Vec<u8>>(),
-        )
+        ))
     }
 
     fn bit_stream_starts_with_h264prefix(&mut self) -> Result<usize> {
-        let prefix_buffer = self.read(4);
+        let prefix_buffer = self.read(4)?;
 
         let n = prefix_buffer.len();
         if n == 0 {
@@ -228,7 +228,7 @@ impl<R: Read> H264Reader<R> {
         }
 
         loop {
-            let buffer = self.read(1);
+            let buffer = self.read(1)?;
             let n = buffer.len();
 
             if n != 1 {

webrtc/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "webrtc"
-version = "0.7.1"
+version = "0.7.2"
 authors = ["Rain Liu <yliu@webrtc.rs>"]
 edition = "2021"
 description = "A pure Rust implementation of WebRTC API"
@@ -19,7 +19,7 @@ dtls = { version = "0.7.1", path = "../dtls", package = "webrtc-dtls" }
 ice = { version = "0.9.0", path = "../ice", package = "webrtc-ice" }
 interceptor = { version = "0.8.2", path = "../interceptor" }
 mdns = { version = "0.5.0", path = "../mdns", package = "webrtc-mdns" }
-media = { version = "0.5.0", path = "../media", package = "webrtc-media" }
+media = { version = "0.5.1", path = "../media", package = "webrtc-media" }
 rtcp = { version = "0.7.0", path = "../rtcp" }
 rtp = { version = "0.6.7", path = "../rtp" }
 sctp = { version = "0.8.0", path = "../sctp", package = "webrtc-sctp" }