(self, limit=_DEFAULT_LIMIT, loop=None)
| 412 | _source_traceback = None |
| 413 | |
| 414 | def __init__(self, limit=_DEFAULT_LIMIT, loop=None): |
| 415 | # The line length limit is a security feature; |
| 416 | # it also doubles as half the buffer limit. |
| 417 | |
| 418 | if limit <= 0: |
| 419 | raise ValueError('Limit cannot be <= 0') |
| 420 | |
| 421 | self._limit = limit |
| 422 | if loop is None: |
| 423 | self._loop = events.get_event_loop() |
| 424 | else: |
| 425 | self._loop = loop |
| 426 | self._buffer = bytearray() |
| 427 | self._eof = False # Whether we're done. |
| 428 | self._waiter = None # A future used by _wait_for_data() |
| 429 | self._exception = None |
| 430 | self._transport = None |
| 431 | self._paused = False |
| 432 | if self._loop.get_debug(): |
| 433 | self._source_traceback = format_helpers.extract_stack( |
| 434 | sys._getframe(1)) |
| 435 | |
| 436 | def __repr__(self): |
| 437 | info = ['StreamReader'] |
nothing calls this directly
no test coverage detected