(self, fut)
| 442 | self._read_fut.add_done_callback(self._pipe_closed) |
| 443 | |
| 444 | def _pipe_closed(self, fut): |
| 445 | if fut.cancelled(): |
| 446 | # the transport has been closed |
| 447 | return |
| 448 | assert fut.result() == b'' |
| 449 | if self._closing: |
| 450 | assert self._read_fut is None |
| 451 | return |
| 452 | assert fut is self._read_fut, (fut, self._read_fut) |
| 453 | self._read_fut = None |
| 454 | if self._write_fut is not None: |
| 455 | self._force_close(BrokenPipeError()) |
| 456 | else: |
| 457 | self.close() |
| 458 | |
| 459 | |
| 460 | class _ProactorDatagramTransport(_ProactorBasePipeTransport, |
nothing calls this directly
no test coverage detected