(self, exc)
| 258 | self._strong_reader = None |
| 259 | |
| 260 | def connection_lost(self, exc): |
| 261 | reader = self._stream_reader |
| 262 | if reader is not None: |
| 263 | if exc is None: |
| 264 | reader.feed_eof() |
| 265 | else: |
| 266 | reader.set_exception(exc) |
| 267 | if not self._closed.done(): |
| 268 | if exc is None: |
| 269 | self._closed.set_result(None) |
| 270 | else: |
| 271 | self._closed.set_exception(exc) |
| 272 | super().connection_lost(exc) |
| 273 | self._stream_reader_wr = None |
| 274 | self._stream_writer = None |
| 275 | self._task = None |
| 276 | self._transport = None |
| 277 | |
| 278 | def data_received(self, data): |
| 279 | reader = self._stream_reader |
nothing calls this directly
no test coverage detected