Lines Matching refs:_Buffer
206 self._buffer = _Buffer()
221 self._buffer.reset(content)
260 self._buffer = _Buffer()
310 newline_offset = self._buffer.find_newline(size)
312 data = self._buffer.read(size)
318 self._buffer.reset(self._buffer_future.get_result())
320 newline_offset = self._buffer.find_newline(size)
322 data = self._buffer.read_to_offset(newline_offset + 1)
348 remaining = self._buffer.remaining()
350 data_list.append(self._buffer.read(size))
356 data_list.append(self._buffer.read())
368 self._buffer.reset(self._buffer_future.get_result())
381 Requires self._offset and self._buffer are in consistent state.
384 next_offset = self._offset + self._buffer.remaining()
480 self._buffer = None
507 self._buffer.reset()
550 class _Buffer(object):
557 self._buffer = content
561 """Returns bytes from self._buffer and update related offsets.
571 offset = len(self._buffer)
577 """Returns bytes from self._buffer and update related offsets.
586 result = self._buffer[self._offset: offset]
591 return len(self._buffer) - self._offset
603 return self._buffer.find('\n', self._offset)
604 return self._buffer.find('\n', self._offset, self._offset + size)
650 self._buffer = collections.deque()
684 'buffer': self._buffer,
698 self._buffer = state['buffer']
720 self._buffer.append(data)
751 self._buffer = None
773 while self._buffer:
774 buf = self._buffer.popleft()
794 self._buffer.appendleft(tail)
