Function streamRequest

web/lib/api/messages.ts:90–113

(
  conversationId: string,
  body: Record<string, unknown>,
  opts?: SendOptions
)

}

async function* streamRequest(
  conversationId: string,
  body: Record<string, unknown>,
  opts?: SendOptions
): AsyncGenerator<StreamEvent> {
  // Cancel any existing stream for this conversation
  activeControllers.get(conversationId)?.abort();
  const controller = new AbortController();
  activeControllers.set(conversationId, controller);

  const signal = combineSignals(opts?.signal, controller.signal);

  try {
    const res = await apiClient.postStream("/api/chat", body, { signal });
    yield* parseStream(res, { signal, onProgress: opts?.onProgress });
  } catch (err) {
    if (err instanceof ApiError && err.type === "abort") return; // stop() was called
    throw err;
  } finally {
    if (activeControllers.get(conversationId) === controller) {
      activeControllers.delete(conversationId);
    }
  }
}

export const messageAPI: MessageAPI = {
  async *send(conversationId, content, history, opts) {