Method connect

web/lib/api/stream.ts:118–145

()

  }

  connect(): void {
    if (this.closed) return;

    this.eventSource = new EventSource(this.url);

    this.eventSource.onopen = () => {
      this.reconnectAttempts = 0;
      this.opts.onConnect?.();
    };

    this.eventSource.onmessage = (e: MessageEvent) => {
      if (typeof e.data !== "string") return;
      if (e.data === "[DONE]") return;
      try {
        const event = JSON.parse(e.data as string) as StreamEvent;
        this.opts.onEvent(event);
      } catch {
        // skip malformed events
      }
    };

    this.eventSource.onerror = () => {
      this.eventSource?.close();
      this.eventSource = null;
      this.opts.onDisconnect?.();
      this.scheduleReconnect();
    };
  }

  disconnect(): void {
    this.closed = true;