Wrap concurrent.futures.Future object.
(future, *, loop=None)
| 413 | |
| 414 | |
| 415 | def wrap_future(future, *, loop=None): |
| 416 | """Wrap concurrent.futures.Future object.""" |
| 417 | if isfuture(future): |
| 418 | return future |
| 419 | assert isinstance(future, concurrent.futures.Future), \ |
| 420 | f'concurrent.futures.Future is expected, got {future!r}' |
| 421 | if loop is None: |
| 422 | loop = events.get_event_loop() |
| 423 | new_future = loop.create_future() |
| 424 | _chain_future(future, new_future) |
| 425 | return new_future |
| 426 | |
| 427 | |
| 428 | def future_add_to_awaited_by(fut, waiter, /): |
nothing calls this directly
no test coverage detected