--- a/mercurial/wireprotov2server.py Sat Apr 14 15:38:11 2018 -0700
+++ b/mercurial/wireprotov2server.py Sun Apr 15 10:37:29 2018 -0700
@@ -306,6 +306,15 @@
action, meta = reactor.oncommandresponseready(outstream,
command['requestid'],
encoded)
+ elif isinstance(rsp, wireprototypes.v2streamingresponse):
+ action, meta = reactor.oncommandresponsereadygen(outstream,
+ command['requestid'],
+ rsp.gen)
+ elif isinstance(rsp, wireprototypes.v2errorresponse):
+ action, meta = reactor.oncommanderror(outstream,
+ command['requestid'],
+ rsp.message,
+ rsp.args)
else:
action, meta = reactor.onservererror(
_('unhandled response type from wire proto command'))