mercurial/util.py

16872:40d930848fd0

                        yield chunk[pos:end]
                        pos = end
                else:
                    yield chunk
        self.iter = splitbig(in_iter)
        self._queue = []

    def read(self, l):
        """Read L bytes of data from the iterator of chunks of data.
        Returns less than L bytes if the iterator runs dry."""
        left = l
        buf = ''
        queue = deque(self._queue)
        while left > 0:
            # refill the queue
            if not queue:
                target = 2**18
                for chunk in self.iter:

            if left < 0:
                queue.appendleft(chunk[left:])
                buf += chunk[:left]
            else:
                buf += chunk
        self._queue = list(queue)

        return buf

def filechunkiter(f, size=65536, limit=None):
    """Create a generator that produces the data in the file size

16873:37e081609828

                        yield chunk[pos:end]
                        pos = end
                else:
                    yield chunk
        self.iter = splitbig(in_iter)
        self._queue = deque()

    def read(self, l):
        """Read L bytes of data from the iterator of chunks of data.
        Returns less than L bytes if the iterator runs dry."""
        left = l
        buf = ''
        queue = self._queue
        while left > 0:
            # refill the queue
            if not queue:
                target = 2**18
                for chunk in self.iter:

            if left < 0:
                queue.appendleft(chunk[left:])
                buf += chunk[:left]
            else:
                buf += chunk

        return buf

def filechunkiter(f, size=65536, limit=None):
    """Create a generator that produces the data in the file size