(&mut self, closure: C)
| 64 | } |
| 65 | |
| 66 | fn push<C, F>(&mut self, closure: C) |
| 67 | where |
| 68 | F: Future<Output = ()> + 'static, |
| 69 | C: FnOnce(Task) -> F, |
| 70 | { |
| 71 | let task = Task { |
| 72 | state: State::Running, |
| 73 | }; |
| 74 | self.tasks.push_back(Box::pin(closure(task))); |
| 75 | } |
| 76 | |
| 77 | fn run(&mut self) { |
| 78 | let waker = create_waker(); |