(self, agen)
| 559 | raise RuntimeError('Executor shutdown has been called') |
| 560 | |
| 561 | def _asyncgen_finalizer_hook(self, agen): |
| 562 | self._asyncgens.discard(agen) |
| 563 | if not self.is_closed(): |
| 564 | self.call_soon_threadsafe(self.create_task, agen.aclose()) |
| 565 | |
| 566 | def _asyncgen_firstiter_hook(self, agen): |
| 567 | if self._asyncgens_shutdown_called: |
nothing calls this directly
no test coverage detected