equal
deleted
inserted
replaced
719 ) |
719 ) |
720 |
720 |
721 r = exchange.unbundle( |
721 r = exchange.unbundle( |
722 repo, gen, their_heads, b'serve', proto.client() |
722 repo, gen, their_heads, b'serve', proto.client() |
723 ) |
723 ) |
724 if util.safehasattr(r, 'addpart'): |
724 if hasattr(r, 'addpart'): |
725 # The return looks streamable, we are in the bundle2 case |
725 # The return looks streamable, we are in the bundle2 case |
726 # and should return a stream. |
726 # and should return a stream. |
727 return wireprototypes.streamreslegacy(gen=r.getchunks()) |
727 return wireprototypes.streamreslegacy(gen=r.getchunks()) |
728 return wireprototypes.pushres( |
728 return wireprototypes.pushres( |
729 r, output.getvalue() if output else b'' |
729 r, output.getvalue() if output else b'' |