mono

Author: surban

remoc/src/rch/base/io.rs

@@ -1,7 +1,5 @@
 use bytes::{Buf, Bytes, BytesMut};
-use std::io::{self, BufWriter};
-
-use crate::chmux::DataBuf;
+use std::io;
 
 /// Writes to an internal memory buffer with a limited maximum size.
 pub struct LimitedBytesWriter {
@@ -82,27 +80,6 @@ impl io::Write for ChannelBytesWriter {
     }
 }
 
-pub(crate) enum IoWriter<'a> {
-    Limited(&'a mut LimitedBytesWriter),
-    Channel(&'a mut BufWriter<ChannelBytesWriter>),
-}
-
-impl<'a> io::Write for IoWriter<'a> {
-    fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
-        match self {
-            Self::Limited(w) => w.write(buf),
-            Self::Channel(w) => w.write(buf),
-        }
-    }
-
-    fn flush(&mut self) -> io::Result<()> {
-        match self {
-            Self::Limited(w) => w.flush(),
-            Self::Channel(w) => w.flush(),
-        }
-    }
-}
-
 /// Reads data from an mpsc channel.
 ///
 /// This must not be used in an async thread.
@@ -140,16 +117,4 @@ impl io::Read for ChannelBytesReader {
     }
 }
 
-pub(crate) enum IoReader<'a, 'b> {
-    DataBuf(&'a mut bytes::buf::Reader<&'b mut DataBuf>),
-    Channel(&'a mut ChannelBytesReader),
-}
 
-impl<'a, 'b> io::Read for IoReader<'a, 'b> {
-    fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> {
-        match self {
-            Self::DataBuf(r) => r.read(buf),
-            Self::Channel(r) => r.read(buf),
-        }
-    }
-}