(packs: TaskResultPack[], events: TaskEventPack[])
| 265 | } |
| 266 | |
| 267 | async onTaskUpdate(packs: TaskResultPack[], events: TaskEventPack[]): Promise<void> { |
| 268 | if (this.clients.size === 0) { |
| 269 | return |
| 270 | } |
| 271 | |
| 272 | this.clients.forEach((client) => { |
| 273 | client.onTaskUpdate?.(packs, events)?.catch?.(noop) |
| 274 | }) |
| 275 | } |
| 276 | |
| 277 | private sum<T>(items: T[], cb: (_next: T) => number | undefined) { |
| 278 | return items.reduce((total, next) => { |
no outgoing calls
no test coverage detected