Fix async compile errors

rmja · Aug 26, 2023 · 6cbacac · 6cbacac
1 parent 36186b8
commit 6cbacac
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/src/asynch/read.rs b/src/asynch/read.rs
@@ -1,4 +1,4 @@
-use embedded_io_asynch::{Read, Write};
+use embedded_io_async::{Read, Write, WriteAllError};
 
 /// A buffered [`Read`]
 ///
@@ -24,7 +24,7 @@ impl<T: Read + Write> Write for BufferedRead<'_, T> {
         self.inner.write(buf).await
     }
 
-    async fn write_all(&mut self, buf: &[u8]) -> Result<(), Self::Error> {
+    async fn write_all(&mut self, buf: &[u8]) -> Result<(), WriteAllError<Self::Error>> {
         self.inner.write_all(buf).await
     }
 

diff --git a/src/asynch/write.rs b/src/asynch/write.rs
@@ -1,4 +1,4 @@
-use embedded_io_asynch::{Read, Write};
+use embedded_io_async::{Read, Write, WriteAllError};
 
 /// A buffered [`Write`]
 ///
@@ -57,7 +57,11 @@ impl<T: Write> Write for BufferedWrite<'_, T> {
 
     async fn flush(&mut self) -> Result<(), Self::Error> {
         if self.pos > 0 {
-            self.inner.write_all(&self.buf[..self.pos]).await?;
+            match self.inner.write_all(&self.buf[..self.pos]).await {
+                Ok(()) => {}
+                Err(WriteAllError::WriteZero) => {}
+                Err(WriteAllError::Other(e)) => return Err(e),
+            }
             self.pos = 0;
         }