(
self, func: Callable[_P, _R], *args: _P.args, **kwargs: _P.kwargs
)
| 279 | return _future_result(future) |
| 280 | |
| 281 | def _submit( |
| 282 | self, func: Callable[_P, _R], *args: _P.args, **kwargs: _P.kwargs |
| 283 | ) -> asyncio.Future[_BackendOutcome[_R]]: |
| 284 | return (self._loop or asyncio.get_running_loop()).run_in_executor( |
| 285 | self._executor, |
| 286 | _capture_call, |
| 287 | functools.partial(func, *args, **kwargs), |
| 288 | ) |
| 289 | |
| 290 | def _shutdown_owned_executor(self) -> None: |
| 291 | if self._owns_executor: |
no test coverage detected