Method chatStream

src/sdk/text/index.ts:8–29

(body: Partial<ChatRequest>)

export class TextSDK extends Client {
  private async *chatStream(body: Partial<ChatRequest>): AsyncGenerator<StreamEvent> {
    const url = chatEndpoint(this.config.baseUrl);

    const res = await this.request({
      url,
      method: 'POST',
      body,
      stream: true,
      authStyle: 'x-api-key',
    });

    const contentType = res.headers.get('content-type') || '';

    if (!contentType.includes('text/event-stream') && !contentType.includes('stream')) {
      throw new SDKError(
        `Expected SSE stream but got content-type "${contentType}". Server may be experiencing issues.`,
        ExitCode.GENERAL,
      );
    }

    yield* this.streamSSE<StreamEvent>(res);
  }

  async chat(request: Partial<ChatRequest> & { stream: true }): Promise<AsyncGenerator<StreamEvent>>;
  async chat(request: Partial<ChatRequest>): Promise<ChatResponse>;