Agent Streaming

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

for await (const event of stream) {
  if (event.type === "text-delta") {
    process.stdout.write(event.delta);
  }
}

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

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

// The StreamIterator resolves with:
// { text, toolCalls, requestId, receipt, budget, sessionInvalidReason }

// Client-side abort
const controller = new AbortController();
const stream = sdk.agent.stream({ /* ... */ }, { signal: controller.signal });
controller.abort();

// Server-side stop
await sdk.agent.stop({
  agentWallet: "0x...",
  runId: "run-id-from-stream",
  threadId: "chat-1",
});

await sdk.agent.decide({
  agentWallet: "0x...",
  runId: "run-id",
  proposalId: "proposal_...",
  version: 1,
  decision: "approved", // or "rejected" or "changes_requested"
  approver: "0xYourWallet",
  reason: "Looks good",
  feedback: "Add more detail to step 2", // for changes_requested
});

const stream = sdk.agent.stream({
  agentWallet: "0x...",
  message: "What's in this image?",
  threadId: "vision-1",
  attachment: {
    type: "image_url",
    image_url: { url: "data:image/png;base64,iVBOR..." },
  },
});

const stream = sdk.agent.stream({
  agentWallet: "0x...",
  message: "Compare these two designs",
  threadId: "compare-1",
  attachments: [
    { type: "image_url", image_url: { url: "https://..." } },
    { type: "image_url", image_url: { url: "https://..." } },
  ],
});