Merge pull request #43 from Byron/master

Support BlockOn for implementors of AsyncBufRead
smol-rs · May 18, 2021 · 0577901 · 0577901
2 parents 5707c10 fe1c64f
commit 0577901
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/src/io.rs b/src/io.rs
@@ -394,6 394,16 @@ impl<T: AsyncRead Unpin> std::io::Read for BlockOn<T> {
  }
 }
 
 impl<T: AsyncBufRead Unpin> std::io::BufRead for BlockOn<T> {
  fn fill_buf(&mut self) -> Result<&[u8]> {
  future::block_on(self.0.fill_buf())
  }
 
  fn consume(&mut self, amt: usize) {
  Pin::new(&mut self.0).consume(amt)
  }
 }
 
 impl<T: AsyncWrite Unpin> std::io::Write for BlockOn<T> {
  fn write(&mut self, buf: &[u8]) -> Result<usize> {
  future::block_on(self.0.write(buf))