Method streamSSE

src/sdk/client.ts:37–50

(res: Response)

  }

  protected async *streamSSE<T>(res: Response): AsyncGenerator<T> {
    for await (const event of parseSSE(res)) {
      if (event.data === '[DONE]') break;
      if (!event.data) continue;
      try {
        yield JSON.parse(event.data) as T;
      } catch (err) {
        throw new SDKError(
          `Failed to parse stream chunk: ${err instanceof Error ? err.message : String(err)}`,
          ExitCode.GENERAL,
        );
      }
    }
  }
}