Streaming Events

for await (const event of stream) {
  switch (event.type) {
    case "turn.started":
      conversationId = event.conversation_id;
      break;
    case "part.started":
    case "part.completed":
      parts[event.part_index] = event.part;
      break;
    case "part.delta":
      text += event.delta;
      break;
    case "turn.completed":
      done(event.message);
      break;
    case "error":
      if (event.retryable) retry();
      else showError(event.message);
      break;
  }
}

for event in stream:
    if event.type == "turn.started":
        conversation_id = event.conversation_id
    elif event.type in ("part.started", "part.completed"):
        parts[event.part_index] = event.part
    elif event.type == "part.delta":
        text += event.delta
    elif event.type == "turn.completed":
        done(event.message)
    elif event.type == "error":
        if event.retryable:
            retry()
        else:
            show_error(event.message)

event: turn.started
data: {"type":"turn.started","conversation_id":"conv_123","turn_id":"turn_…","message_id":"msg_…"}

event: part.delta
data: {"type":"part.delta","part_index":0,"delta":"Let me pull up some options."}

event: part.completed
data: {"type":"part.completed","part_index":1,"part":{"type":"tool","tool_name":"search_products",…}}

event: turn.completed
data: {"type":"turn.completed","message":{"parts":[ … ]},"usage":{"credits_charged":2,"searches_run":1}}