diff --git a/libmproxy/protocol/http.py b/libmproxy/protocol/http.py
index dbe91e3c9..a05f3597e 100644
--- a/libmproxy/protocol/http.py
+++ b/libmproxy/protocol/http.py
@@ -45,12 +45,23 @@ class _StreamingHttpLayer(_HttpLayer):
         raise NotImplementedError()
         yield "this is a generator"  # pragma: no cover
 
+    def read_response(self, request_method):
+        response = self.read_response_headers()
+        response.body = "".join(
+            self.read_response_body(response.headers, request_method, response.code)
+        )
+        return response
+
     def send_response_headers(self, response):
         raise NotImplementedError
 
     def send_response_body(self, response, chunks):
         raise NotImplementedError()
 
+    def send_response(self, response):
+        self.send_response_headers(response)
+        self.send_response_body(response, response.body)
+
 
 class Http1Layer(_StreamingHttpLayer):
     def __init__(self, ctx, mode):
@@ -68,17 +79,6 @@ class Http1Layer(_StreamingHttpLayer):
     def send_request(self, request):
         self.server_conn.send(self.server_protocol.assemble(request))
 
-    def read_response(self, request_method):
-        return HTTPResponse.from_protocol(
-            self.server_protocol,
-            request_method=request_method,
-            body_size_limit=self.config.body_size_limit,
-            include_body=True
-        )
-
-    def send_response(self, response):
-        self.client_conn.send(self.client_protocol.assemble(response))
-
     def read_response_headers(self):
         return HTTPResponse.from_protocol(
             self.server_protocol,