Fix StreamExt::forward impl by calling poll_flush()

ebkalderon · ebkalderon · commit 633c7f1f1fbb · 2019-01-29T00:26:53.000+08:00
diff --git a/futures-util/src/stream/forward.rs b/futures-util/src/stream/forward.rs
@@ -39,7 +39,7 @@ where
         Forward {
             sink: Some(sink),
             stream: stream.fuse(),
-                buffered_item: None,
+            buffered_item: None,
         }
     }
 
@@ -90,7 +90,7 @@ where
                 Poll::Ready(Some(Err(e))) => return Poll::Ready(Err(e)),
                 Poll::Ready(None) => {
                     try_ready!(self.as_mut().sink().as_pin_mut().expect(INVALID_POLL)
-                                   .poll_close(lw));
+                                   .poll_flush(lw));
                     return Poll::Ready(Ok(self.as_mut().sink().take().unwrap()))
                 }
                 Poll::Pending => {

Original file line number	Diff line number	Diff line change
`@@ -39,7 +39,7 @@ where`
`39`	`39`	`Forward {`
`40`	`40`	`sink: Some(sink),`
`41`	`41`	`stream: stream.fuse(),`
`42`		`- buffered_item: None,`
	`42`	`+ buffered_item: None,`
`43`	`43`	`}`
`44`	`44`	`}`
`45`	`45`
`@@ -90,7 +90,7 @@ where`
`90`	`90`	`Poll::Ready(Some(Err(e))) => return Poll::Ready(Err(e)),`
`91`	`91`	`Poll::Ready(None) => {`
`92`	`92`	`try_ready!(self.as_mut().sink().as_pin_mut().expect(INVALID_POLL)`
`93`		`- .poll_close(lw));`
	`93`	`+ .poll_flush(lw));`
`94`	`94`	`return Poll::Ready(Ok(self.as_mut().sink().take().unwrap()))`
`95`	`95`	`}`
`96`	`96`	`Poll::Pending => {`