(taskId: string)
| 286 | * Call this when a task completes and its output has been consumed. |
| 287 | */ |
| 288 | export function evictTaskOutput(taskId: string): Promise<void> { |
| 289 | return track( |
| 290 | (async () => { |
| 291 | const output = outputs.get(taskId) |
| 292 | if (output) { |
| 293 | await output.flush() |
| 294 | outputs.delete(taskId) |
| 295 | } |
| 296 | })(), |
| 297 | ) |
| 298 | } |
| 299 | |
| 300 | /** |
| 301 | * Get delta (new content) since last read. |
no test coverage detected