diff --git a/src/pipeline.rs b/src/pipeline.rs
index bd7801a3..b895be8c 100644
--- a/src/pipeline.rs
+++ b/src/pipeline.rs
@@ -482,10 +482,14 @@ impl<S: 'static, H> ProcessResponse<S, H> {
                         }
 
                         match self.resp.replace_body(Body::Empty) {
-                            Body::Streaming(stream) =>
-                                self.iostate = IOState::Payload(stream),
-                            Body::Actor(ctx) =>
-                                self.iostate = IOState::Actor(ctx),
+                            Body::Streaming(stream) => {
+                                self.iostate = IOState::Payload(stream);
+                                continue
+                            },
+                            Body::Actor(ctx) => {
+                                self.iostate = IOState::Actor(ctx);
+                                continue
+                            },
                             _ => (),
                         }