(self, command: Callable[[], None])
| 15482 | self.scheduler.close() |
| 15483 | |
| 15484 | def enqueue(self, command: Callable[[], None]) -> None: |
| 15485 | with self.condition: |
| 15486 | if self.closed: |
| 15487 | raise RuntimeError("completion service closed") |
| 15488 | self.commands.append(command) |
| 15489 | self.condition.notify_all() |
| 15490 | |
| 15491 | def call_on_scheduler(self, callback: Callable[[], Any]) -> Any: |
| 15492 | result_box: Dict[str, Any] = {} |
no test coverage detected