Method loop

src/api/stream.ts:113–148

(signal: AbortSignal)

    while (!signal.aborted) {
      const data = this.resetOnReconnect ? this.createInitial() : this.snapshot.data;
      if (this.snapshot.phase !== "error") {
        this.setSnapshot({ phase: "connecting", data });
      } else if (this.resetOnReconnect) {
        this.setSnapshot({ ...this.snapshot, data });
      }
      try {
        await this.runStream({
          signal,
          update: (updater) => {
            attempt = 0;
            this.setSnapshot({ phase: "active", data: updater(this.snapshot.data) });
          },
        });
      } catch (error) {
        if (signal.aborted) {
          return;
        }
        const described = describeError(error);
        this.setSnapshot({
          ...this.snapshot,
          phase: "error",
          error: described.message,
          errorCode: described.code,
        });
        if (isTerminalCode(described.code)) {
          return;
        }
      }
      attempt += 1;
      await this.backoff(Math.min(1000 * attempt, 5000), signal);
      if (this.skipBackoff) {
        this.skipBackoff = false;
        attempt = 0;
      }
    }
  }

  private backoff(durationMs: number, signal: AbortSignal): Promise<void> {
    return new Promise((resolve) => {