--- a/mercurial/wireprotoserver.py	Mon Mar 26 13:51:22 2018 -0700
+++ b/mercurial/wireprotoserver.py	Mon Mar 26 13:57:22 2018 -0700
@@ -546,9 +546,11 @@
 
     res.status = b'200 OK'
     res.headers[b'Content-Type'] = FRAMINGTYPE
+    stream = wireprotoframing.stream()
 
     if isinstance(rsp, wireprototypes.bytesresponse):
-        action, meta = reactor.onbytesresponseready(command['requestid'],
+        action, meta = reactor.onbytesresponseready(stream,
+                                                    command['requestid'],
                                                     rsp.data)
     else:
         action, meta = reactor.onapplicationerror(