Remove unneccessary poll_complete when emptying buffer
@@ -48,9 +48,6 @@ impl<S: Sink> Buffer<S> {
if let AsyncSink::Pending(item) = self.sink.start_send(cx, item)? {
self.buf.push_front(item);
- // ensure that we attempt to complete any pushes we've started
- self.sink.flush(cx)?;
-
return Ok(Async::Pending);
}
}
