Forward Stream through SinkMapErr

Author: alexcrichton

src/sink/map_err.rs

@@ -1,6 +1,6 @@
 use sink::Sink;
 
-use {Poll, StartSend};
+use {Poll, StartSend, Stream};
 
 /// Sink for the `Sink::sink_map_err` combinator.
 #[derive(Debug)]
@@ -53,3 +53,12 @@ impl<S, F, E> Sink for SinkMapErr<S, F>
         self.sink.close().map_err(|e| self.f.take().expect("cannot use MapErr after an error")(e))
     }
 }
+
+impl<S: Stream, F> Stream for SinkMapErr<S, F> {
+    type Item = S::Item;
+    type Error = S::Error;
+
+    fn poll(&mut self) -> Poll<Option<S::Item>, S::Error> {
+        self.sink.poll()
+    }
+}