(self)
| 135 | return future.result() |
| 136 | |
| 137 | def shutdown(self) -> None: |
| 138 | if self._closed: |
| 139 | return |
| 140 | self._loop.call_soon_threadsafe(self._loop.stop) |
| 141 | self._thread.join() |
| 142 | self._loop.close() |
| 143 | self._closed = True |
| 144 | |
| 145 | |
| 146 | class ToolCallingAgentRunner: |