(task: ScheduledTask)
| 4 | |
| 5 | export class TaskRegistry { |
| 6 | add(task: ScheduledTask): void{ |
| 7 | if(this.has(task.id)){ |
| 8 | throw Error(`task ${task.id} already registered!`) |
| 9 | } |
| 10 | |
| 11 | tasks.set(task.id, task); |
| 12 | |
| 13 | task.on('task:destroyed', () => { |
| 14 | this.remove(task); |
| 15 | }); |
| 16 | } |
| 17 | |
| 18 | get(taskId: string): ScheduledTask | undefined { |
| 19 | return tasks.get(taskId); |
no test coverage detected