Function waitForStreamStarted

src/cli/run.ts:917–940

(timeoutMs?: number)

  };

  const waitForStreamStarted = async (timeoutMs?: number): Promise<void> => {
    let timer: ReturnType<typeof setTimeout> | null = null;
    const streamFailedOrEndedBeforeStart = completionPromise.then(() => {
      throw new Error("Goal continuation stream ended before it started");
    });
    const waits: Array<Promise<void>> = [streamStartedPromise, streamFailedOrEndedBeforeStart];
    if (timeoutMs != null) {
      waits.push(
        new Promise<never>((_, reject) => {
          timer = setTimeout(() => {
            reject(new Error("Timed out waiting for goal continuation stream to start"));
          }, timeoutMs);
          timer.unref?.();
        })
      );
    }
    try {
      await Promise.race(waits);
    } finally {
      if (timer != null) {
        clearTimeout(timer);
      }
    }
  };

  const resetCompletionHandlers = () => {
    resolveCompletion = null;