Revert to poll_close() with #1441 merged

ebkalderon · ebkalderon · commit 8a2d6f70d33f · 2019-02-15T20:26:21.000+08:00
diff --git a/futures-util/src/stream/forward.rs b/futures-util/src/stream/forward.rs
@@ -84,7 +84,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_flush(lw));
+                                   .poll_close(lw));
                     self.as_mut().sink().set(None);
                     return Poll::Ready(Ok(()))
                 }

Original file line number	Diff line number	Diff line change
`@@ -84,7 +84,7 @@ where`
`84`	`84`	`Poll::Ready(Some(Err(e))) => return Poll::Ready(Err(e)),`
`85`	`85`	`Poll::Ready(None) => {`
`86`	`86`	`try_ready!(self.as_mut().sink().as_pin_mut().expect(INVALID_POLL)`
`87`		`- .poll_flush(lw));`
	`87`	`+ .poll_close(lw));`
`88`	`88`	`self.as_mut().sink().set(None);`
`89`	`89`	`return Poll::Ready(Ok(()))`
`90`	`90`	`}`