(self, data, size)
| 573 | self._stream.paused = False |
| 574 | |
| 575 | def feed_data(self, data, size): |
| 576 | has_waiter = self._waiter is not None and not self._waiter.cancelled() |
| 577 | |
| 578 | super().feed_data(data, size) |
| 579 | |
| 580 | if (not self._stream.paused and |
| 581 | not has_waiter and self._size > self._limit): |
| 582 | try: |
| 583 | self._stream.transport.pause_reading() |
| 584 | except (AttributeError, NotImplementedError): |
| 585 | pass |
| 586 | else: |
| 587 | self._stream.paused = True |
| 588 | |
| 589 | @asyncio.coroutine |
| 590 | def read(self): |