(reason: Optional[str])
| 54 | self.on_message(cast(ParsedMessagePayload, message)) |
| 55 | |
| 56 | def handle_closed(reason: Optional[str]) -> None: |
| 57 | self.emit("close", reason) |
| 58 | if reason: |
| 59 | self.on_error_future.set_exception(TargetClosedError(reason)) |
| 60 | self._stopped_future.set_result(None) |
| 61 | |
| 62 | self._pipe_channel.on( |
| 63 | "message", |
nothing calls this directly
no test coverage detected