Workflow Streaming

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

for await (const event of stream) {
  switch (event.type) {
    case "step":
      console.log(`Step ${event.data.stepIndex}/${event.data.totalSteps}: ${event.data.stepName}`);
      break;
    case "agent":
      console.log(`Agent: ${event.data.agentName}`);
      break;
    case "text-delta":
      process.stdout.write(event.delta);
      break;
    case "done":
      console.log(`\nDone. Tokens: ${event.usage.total_tokens}`);
      break;
  }
}

await sdk.workflow.stop({
  workflowWallet: "0x...",
  runId: "run-id",
  threadId: "wf-1",
});

sdk.events.on("workflowStreamStart", (event) => {
  console.log("Workflow started:", event.workflowWallet);
});

sdk.events.on("workflowStreamEnd", (event) => {
  console.log("Workflow ended:", event.workflowWallet);
});