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