watchChat

streaming.chats.watchChat(request, options?) → AsyncIterable<WatchChatEvent>

import { createStreamingClient } from "@textql/sdk/streaming";

const streaming = createStreamingClient({ apiKey: process.env.TEXTQL_API_KEY! });

for await (const event of streaming.chats.watchChat({
  chatId,
  latestCompleteCellId: lastSeenCellId, // omit to replay the whole chat
})) {
  switch (event.payload.case) {
    case "runStarted":
      showSpinner();
      break;
    case "cell":
      upsertCell(event.payload.value); // typed Cell — see the Cell reference
      break;
    case "runComplete":
      hideSpinner();
      console.log("final cell:", event.payload.value.finalCellId);
      break;
    case "runError":
      showError(event.payload.value.error);
      break;
    // "opened", "heartbeat", "handoffPending": safe to ignore
  }
}