diff --git a/src/proto/streams/recv.rs b/src/proto/streams/recv.rs index ef2064ee..4009fd11 100644 --- a/src/proto/streams/recv.rs +++ b/src/proto/streams/recv.rs @@ -377,6 +377,11 @@ impl Recv { // If it's not, we put it back if let Some(event) = stream.pending_recv.pop_front(&mut self.buffer) { match event { + Event::Headers(Client(response)) => { + // Final response + stream.pending_recv.push_front(&mut self.buffer, Event::Headers(Client(response))); + return Poll::Ready(None); + } Event::InformationalHeaders(Client(response)) => { // Found an informational response, return it return Poll::Ready(Some(Ok(response)));