Streaming

curl -N https://api.in.talqing.com/v1/conversations/9c2f1a44-3d0b-4a6e-8f21-5b7c0e93a4d1/events \
  -H "Authorization: Bearer $TALQING_API_KEY" \
  -H "Accept: text/event-stream"

// Streams come back as an async iterable of typed frames. Narrow on `event`.
const controller = new AbortController();
const { stream } = await talqing.conversations.events(
  { conversation_id: conversationId },
  { signal: controller.signal },
);

let reply = "";
for await (const frame of stream) {
  switch (frame.event) {
    case "conversation.snapshot":
      console.log(frame.items.length, "items so far");
      break;
    case "assistant.delta":
      reply += frame.text; // append — never cumulative
      break;
    case "assistant.completed":
      reply = frame.text ?? reply; // authoritative; replace
      console.log(reply);
      break;
    case "turn":
      if (frame.status !== "running") controller.abort();
      break;
  }
}

# Streams are context managers. Use one when the loop may exit early, so the
# connection closes with it.
reply = ""
with talqing.conversations.events(conversation_id) as events:
    for frame in events:
        if frame["event"] == "conversation.snapshot":
            print(len(frame["items"]), "items so far")
        elif frame["event"] == "assistant.delta":
            reply += frame["text"]  # append — never cumulative
        elif frame["event"] == "assistant.completed":
            reply = frame["text"] or reply  # authoritative; replace
            print(reply)
        elif frame["event"] == "turn" and frame["status"] != "running":
            break