(&'static self, f: F)
| 722 | let (runnable, task) = |
| 723 | unsafe { async_task::spawn_unchecked(self, schedule_task) }; |
| 724 | |
| 725 | // Perform the initial schedule via the task's own stored schedule |
| 726 | // function, pushing a `JobRef` for the future onto the current worker's |
| 727 | // queue. If the future doesn't complete, it can be woken and scheduled |
| 728 | // again later. |
| 729 | runnable.schedule(); |
| 730 | |
| 731 | // Return the task. |
| 732 | task |