Home | History | Annotate | Download | only in asyncio

Lines Matching refs:_buffer

350         self._buffer = bytearray()
359 if self._buffer:
360 info.append('%d bytes' % len(self._buffer))
400 if self._paused and len(self._buffer) <= self._limit:
410 return self._eof and not self._buffer
418 self._buffer.extend(data)
423 len(self._buffer) > 2 * self._limit):
486 if self._buffer.startswith(sep, e.consumed):
487 del self._buffer[:e.consumed + seplen]
489 self._buffer.clear()
546 buflen = len(self._buffer)
551 isep = self._buffer.find(separator, offset)
570 chunk = bytes(self._buffer)
571 self._buffer.clear()
581 chunk = self._buffer[:isep + seplen]
582 del self._buffer[:isep + seplen]
616 # collect everything in self._buffer, but that would
627 if not self._buffer and not self._eof:
631 data = bytes(self._buffer[:n])
632 del self._buffer[:n]
662 while len(self._buffer) < n:
664 incomplete = bytes(self._buffer)
665 self._buffer.clear()
670 if len(self._buffer) == n:
671 data = bytes(self._buffer)
672 self._buffer.clear()
674 data = bytes(self._buffer[:n])
675 del self._buffer[:n]