Streaming

import sys
from opperai.agent import Agent, tool

agent = Agent(name="weather", instructions="...", tools=[get_weather])

stream = agent.stream("What's the weather in Paris and Tokyo?")

async for event in stream:
    match event.type:
        case "iteration_start":
            print(f"\n[Iteration {event.iteration}]")
        case "text_delta":
            sys.stdout.write(event.text)
            sys.stdout.flush()
        case "tool_start":
            print(f"-> {event.name}({event.input})")
        case "tool_end":
            print(f"<- {event.name} -> {event.output} ({event.duration_ms:.0f}ms)")

result = await stream.result()
print("\nFinal:", result.output)

import { Agent } from "opperai";

const agent = new Agent({ name: "weather", instructions: "...", tools: [getWeather] });

const stream = agent.stream("What's the weather in Paris and Tokyo?");

for await (const event of stream) {
  switch (event.type) {
    case "iteration_start":
      console.log(`\n[Iteration ${event.iteration}]`);
      break;
    case "text_delta":
      process.stdout.write(event.text);
      break;
    case "tool_start":
      console.log(`-> ${event.name}(${JSON.stringify(event.input)})`);
      break;
    case "tool_end":
      console.log(`<- ${event.name} -> ${JSON.stringify(event.output)} (${event.durationMs}ms)`);
      break;
  }
}

const result = await stream.result();
console.log("\nFinal:", result.output);