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 = |
|
|
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