MCPcopy
hub / github.com/coder/mux / rejectWaiters

Method rejectWaiters

src/node/services/taskService.ts:9674–9689  ·  view source on GitHub ↗
(taskId: string, error: Error)

Source from the content-addressed store, hash-verified

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--) {

Calls 2

getMethod · 0.65

Tested by

no test coverage detected