(self)
| 279 | reader.feed_data(data) |
| 280 | |
| 281 | def eof_received(self): |
| 282 | reader = self._stream_reader |
| 283 | if reader is not None: |
| 284 | reader.feed_eof() |
| 285 | if self._over_ssl: |
| 286 | # Prevent a warning in SSLProtocol.eof_received: |
| 287 | # "returning true from eof_received() |
| 288 | # has no effect when using ssl" |
| 289 | return False |
| 290 | return True |
| 291 | |
| 292 | def _get_close_waiter(self, stream): |
| 293 | return self._closed |