(task: Task, milliseconds: number)
| 17 | } |
| 18 | |
| 19 | runPeriodically(task: Task, milliseconds: number): void { |
| 20 | let pending = false; |
| 21 | this.intervals.push( |
| 22 | setInterval(() => { |
| 23 | if (pending) return; |
| 24 | pending = true; |
| 25 | this.run(task).finally(() => { |
| 26 | pending = false; |
| 27 | }); |
| 28 | }, milliseconds) |
| 29 | ); |
| 30 | } |
| 31 | |
| 32 | async stop() { |
| 33 | this.tasks.length = 0; |