Merge pull request #704 from Conaclos/slice_specialized_impls

[io] Specialize `read_exact` and `write_all` for slices and `Vec`

Author: Dirbaio

embedded-io-async/src/impls/slice_mut.rs

@@ -24,4 +24,13 @@ impl Write for &mut [u8] {
         *self = b;
         Ok(amt)
     }
+
+    #[inline]
+    async fn write_all(&mut self, buf: &[u8]) -> Result<(), Self::Error> {
+        if self.len() < buf.len() {
+            return Err(SliceWriteError::Full);
+        }
+        self.write(buf).await?;
+        Ok(())
+    }
 }

embedded-io-async/src/impls/slice_ref.rs

@@ -22,6 +22,17 @@ impl Read for &[u8] {
         *self = b;
         Ok(amt)
     }
+
+    async fn read_exact(
+        &mut self,
+        buf: &mut [u8],
+    ) -> Result<(), embedded_io::ReadExactError<Self::Error>> {
+        if self.len() < buf.len() {
+            return Err(crate::ReadExactError::UnexpectedEof);
+        }
+        self.read(buf).await?;
+        Ok(())
+    }
 }
 
 impl BufRead for &[u8] {

embedded-io-async/src/impls/vec.rs

@@ -9,4 +9,10 @@ impl Write for Vec<u8> {
         self.extend_from_slice(buf);
         Ok(buf.len())
     }
+
+    #[inline]
+    async fn write_all(&mut self, buf: &[u8]) -> Result<(), Self::Error> {
+        self.write(buf).await?;
+        Ok(())
+    }
 }

embedded-io/src/impls/slice_mut.rs

@@ -42,6 +42,15 @@ impl Write for &mut [u8] {
         Ok(amt)
     }
 
+    #[inline]
+    fn write_all(&mut self, buf: &[u8]) -> Result<(), Self::Error> {
+        if self.len() < buf.len() {
+            return Err(SliceWriteError::Full);
+        }
+        self.write(buf)?;
+        Ok(())
+    }
+
     #[inline]
     fn flush(&mut self) -> Result<(), Self::Error> {
         Ok(())

embedded-io/src/impls/slice_ref.rs

@@ -26,6 +26,15 @@ impl Read for &[u8] {
         *self = b;
         Ok(amt)
     }
+
+    #[inline]
+    fn read_exact(&mut self, buf: &mut [u8]) -> Result<(), crate::ReadExactError<Self::Error>> {
+        if self.len() < buf.len() {
+            return Err(crate::ReadExactError::UnexpectedEof);
+        }
+        self.read(buf)?;
+        Ok(())
+    }
 }
 
 impl BufRead for &[u8] {

embedded-io/src/impls/vec.rs

@@ -14,6 +14,12 @@ impl Write for Vec<u8> {
         Ok(buf.len())
     }
 
+    #[inline]
+    fn write_all(&mut self, buf: &[u8]) -> Result<(), Self::Error> {
+        self.write(buf)?;
+        Ok(())
+    }
+
     #[inline]
     fn flush(&mut self) -> Result<(), Self::Error> {
         Ok(())