Skip to content

Commit aa3f838

Browse files
committed
feat: make async Write::flush a required method
1 parent e12dbf6 commit aa3f838

File tree

3 files changed

+11
-3
lines changed

3 files changed

+11
-3
lines changed

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

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,4 +24,9 @@ impl Write for &mut [u8] {
2424
*self = b;
2525
Ok(amt)
2626
}
27+
28+
#[inline]
29+
async fn flush(&mut self) -> Result<(), Self::Error> {
30+
Ok(())
31+
}
2732
}

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

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,4 +9,9 @@ impl Write for Vec<u8> {
99
self.extend_from_slice(buf);
1010
Ok(buf.len())
1111
}
12+
13+
#[inline]
14+
async fn flush(&mut self) -> Result<(), Self::Error> {
15+
Ok(())
16+
}
1217
}

embedded-io-async/src/lib.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -127,9 +127,7 @@ pub trait Write: ErrorType {
127127
async fn write(&mut self, buf: &[u8]) -> Result<usize, Self::Error>;
128128

129129
/// Flush this output stream, ensuring that all intermediately buffered contents reach their destination.
130-
async fn flush(&mut self) -> Result<(), Self::Error> {
131-
Ok(())
132-
}
130+
async fn flush(&mut self) -> Result<(), Self::Error>;
133131

134132
/// Write an entire buffer into this writer.
135133
///

0 commit comments

Comments
 (0)