(taskId: string, error: Error)
| 9672 | } |
| 9673 | |
| 9674 | private rejectWaiters(taskId: string, error: Error): void { |
| 9675 | this.markTaskForegroundRelevant(taskId); |
| 9676 | |
| 9677 | const waiters = this.pendingWaitersByTaskId.get(taskId); |
| 9678 | if (!waiters || waiters.length === 0) { |
| 9679 | return; |
| 9680 | } |
| 9681 | |
| 9682 | for (const waiter of [...waiters]) { |
| 9683 | try { |
| 9684 | waiter.reject(error); |
| 9685 | } catch (rejectError: unknown) { |
| 9686 | log.error("Task waiter reject callback failed", { taskId, error: rejectError }); |
| 9687 | } |
| 9688 | } |
| 9689 | } |
| 9690 | |
| 9691 | private findProposePlanSuccessInParts(parts: readonly unknown[]): { planPath: string } | null { |
| 9692 | for (let i = parts.length - 1; i >= 0; i--) { |
no test coverage detected