(self, data, size=0)
| 522 | pass |
| 523 | |
| 524 | def feed_data(self, data, size=0): |
| 525 | has_waiter = self._waiter is not None and not self._waiter.cancelled() |
| 526 | |
| 527 | super().feed_data(data) |
| 528 | |
| 529 | if (not self._stream.paused and |
| 530 | not has_waiter and self._buffer_size > self._b_limit): |
| 531 | try: |
| 532 | self._stream.transport.pause_reading() |
| 533 | except (AttributeError, NotImplementedError): |
| 534 | pass |
| 535 | else: |
| 536 | self._stream.paused = True |
| 537 | |
| 538 | @maybe_resume |
| 539 | def read(self, n=-1): |