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