(self: Any, *args: Any, **kwargs: Any)
| 118 | |
| 119 | @functools.wraps(fn) |
| 120 | def wrapper(self: Any, *args: Any, **kwargs: Any) -> Future: |
| 121 | async_future = Future() # type: Future |
| 122 | conc_future = getattr(self, executor).submit(fn, self, *args, **kwargs) |
| 123 | chain_future(conc_future, async_future) |
| 124 | return async_future |
| 125 | |
| 126 | return wrapper |
| 127 |
nothing calls this directly
no test coverage detected