Stream AgentRail task events with the TypeScript SDK

const controller = new AbortController();

for await (const event of client.streamEvents({
  eventTypes: ["task.updated", "task.reviewed", "task.shipped"],
  heartbeatSeconds: 30,
  signal: controller.signal,
})) {
  console.log(event.id, event.type);
}

const controller = new AbortController();

// Stop after 60 seconds
setTimeout(() => controller.abort(), 60_000);

for await (const event of client.streamEvents({
  eventTypes: ["task.updated"],
  signal: controller.signal,
})) {
  console.log(event.id, event.type);
}

let lastEventId: string | undefined;

for await (const event of client.streamEvents({
  eventTypes: ["task.updated", "task.reviewed", "task.shipped"],
  heartbeatSeconds: 30,
  cursor: lastEventId,
  signal: controller.signal,
})) {
  lastEventId = event.id;
  console.log(event.id, event.type);
}