(self)
| 35 | self._pipe_channel = pipe_channel |
| 36 | |
| 37 | def request_stop(self) -> None: |
| 38 | self._stop_requested = True |
| 39 | self._pipe_channel.send_no_reply("close", None, {}) |
| 40 | |
| 41 | def dispose(self) -> None: |
| 42 | self.on_error_future.cancel() |
nothing calls this directly
no test coverage detected