##// END OF EJS Templates
util: simplify queue management in chunkbuffer...
Bryan O'Sullivan -
r16873:37e08160 default
parent child Browse files
Show More
@@ -870,14 +870,14 b' class chunkbuffer(object):'
870 870 else:
871 871 yield chunk
872 872 self.iter = splitbig(in_iter)
873 self._queue = []
873 self._queue = deque()
874 874
875 875 def read(self, l):
876 876 """Read L bytes of data from the iterator of chunks of data.
877 877 Returns less than L bytes if the iterator runs dry."""
878 878 left = l
879 879 buf = ''
880 queue = deque(self._queue)
880 queue = self._queue
881 881 while left > 0:
882 882 # refill the queue
883 883 if not queue:
@@ -897,7 +897,6 b' class chunkbuffer(object):'
897 897 buf += chunk[:left]
898 898 else:
899 899 buf += chunk
900 self._queue = list(queue)
901 900
902 901 return buf
903 902
General Comments 0
You need to be logged in to leave comments. Login now