Method chatStream

client-sdks/client-js/src/resources/agent.ts:140–191

* 与 Agent 对话（流式） * @param agentId Agent ID * @param request Chat 请求 * @returns AsyncIterable 流式事件

(agentId: string, request: ChatRequest)

   * @returns AsyncIterable 流式事件
   */
  async *chatStream(agentId: string, request: ChatRequest): AsyncIterable<StreamChatEvent> {
    const response = await fetch(`${this.options.baseUrl}/v1/agents/${agentId}/chat/stream`, {
      method: "POST",
      headers: {
        "Content-Type": "application/json",
        ...(this.options.apiKey && {
          Authorization: `Bearer ${this.options.apiKey}`,
        }),
      },
      body: JSON.stringify(request),
    });

    if (!response.ok) {
      throw new Error(`Chat stream failed: ${response.statusText}`);
    }

    const reader = response.body?.getReader();
    if (!reader) {
      throw new Error("Response body is not readable");
    }

    const decoder = new TextDecoder();
    let buffer = "";

    try {
      while (true) {
        const { done, value } = await reader.read();
        if (done) break;

        buffer += decoder.decode(value, { stream: true });
        const lines = buffer.split("\n");
        buffer = lines.pop() || "";

        for (const line of lines) {
          if (line.startsWith("data: ")) {
            const data = line.slice(6);
            if (data === "[DONE]") {
              return;
            }
            try {
              const event = JSON.parse(data) as StreamChatEvent;
              yield event;
            } catch (error) {
              console.error("Failed to parse SSE data:", data);
            }
          }
        }
      }
    } finally {
      reader.releaseLock();
    }
  }

  // ==========================================================================
  // Agent Templates