We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 56cf384 commit ba8cf1cCopy full SHA for ba8cf1c
1 file changed
msgpack/fallback.py
@@ -202,12 +202,17 @@ def feed(self, next_bytes):
202
self._fb_buffers.append(next_bytes)
203
204
def _fb_consume(self):
205
- self._fb_buffers = self._fb_buffers[self._fb_buf_i:]
+ if self._fb_buf_i:
206
+ for i in xrange(self._fb_buf_i):
207
+ self._fb_buf_n -= len(self._fb_buffers[i])
208
+ self._fb_buffers = self._fb_buffers[self._fb_buf_i:]
209
+ self._fb_buf_i = 0
210
if self._fb_buffers:
211
self._fb_buffers[0] = self._fb_buffers[0][self._fb_buf_o:]
212
+ self._fb_buf_n -= self._fb_buf_o
213
+ else:
214
+ self._fb_buf_n = 0
215
self._fb_buf_o = 0
- self._fb_buf_i = 0
- self._fb_buf_n = sum(map(len, self._fb_buffers))
216
217
def _fb_got_extradata(self):
218
if self._fb_buf_i != len(self._fb_buffers):
0 commit comments