diff --git a/src/task.rs b/src/task.rs index ee64106a8..457519c4c 100644 --- a/src/task.rs +++ b/src/task.rs @@ -399,12 +399,7 @@ impl Task { self.response = ResponseState::Ready(msg); break }, - Frame::Payload(_) => (), - Frame::Drain(fut) => { - self.drain.push(fut); - self.stream = TaskStream::Context(context); - break - } + Frame::Payload(_) | Frame::Drain(_) => (), } }, Ok(Async::Ready(None)) => {