Agent Streaming

const stream = sdk.agent.stream({
  agentWallet: "0xa7abfd271130c3ee5c8f8862a123f3697e75af0d",
  message: "What can you do?",
  threadId: "chat-1",
});

for await (const event of stream) {
  switch (event.type) {
    case "text-delta":
      process.stdout.write(event.delta);
      break;
    case "tool_start":
      console.log(`\n[Tool: ${event.toolName}]`);
      break;
    case "tool_end":
      console.log(`[Done: ${event.toolName}]`);
      break;
    case "done":
      console.log(`\nTokens: ${event.usage.total_tokens}`);
      break;
  }
}

const stream = sdk.agent.stream({ /* ... */ });

for await (const event of stream) {
  // handle events
}

// After the loop, get the final result:
const final = await stream.next(); // { done: true, value: finalResult }
// final.value.text — full response text
// final.value.toolCalls — array of tool call summaries
// final.value.receipt — settlement receipt
// final.value.budget — remaining session budget

const controller = new AbortController();

const stream = sdk.agent.stream({
  agentWallet: "0x...",
  message: "Long task...",
  threadId: "t1",
}, { signal: controller.signal });

// Cancel after 5 seconds
setTimeout(() => controller.abort(), 5000);

await sdk.agent.stop({
  agentWallet: "0x...",
  runId: "the-run-id",
  threadId: "t1",
});

const stream = sdk.workflow.stream({
  workflowWallet: "0xWorkflowWallet",
  message: "Analyze my portfolio",
  threadId: "wf-1",
});