--- a/mercurial/wireprotov2peer.py Tue Aug 28 15:37:55 2018 -0700
+++ b/mercurial/wireprotov2peer.py Tue Aug 28 15:41:09 2018 -0700
@@ -8,15 +8,15 @@
from __future__ import absolute_import
from .i18n import _
-from .thirdparty import (
- cbor,
-)
from . import (
encoding,
error,
util,
wireprotoframing,
)
+from .utils import (
+ cborutil,
+)
def formatrichmessage(atoms):
"""Format an encoded message from the framing protocol."""
@@ -44,13 +44,10 @@
def cborobjects(self):
"""Obtain decoded CBOR objects from this response."""
- size = self.b.tell()
self.b.seek(0)
- decoder = cbor.CBORDecoder(self.b)
-
- while self.b.tell() < size:
- yield decoder.decode()
+ for v in cborutil.decodeall(self.b.getvalue()):
+ yield v
class clienthandler(object):
"""Object to handle higher-level client activities.