streamAppActivity

streaming.apps.streamAppActivity(request, options?) → AsyncIterable<AppActivityStreamEvent>

import { createStreamingClient } from "@textql/sdk/streaming";

const streaming = createStreamingClient({ apiKey });

for await (const event of streaming.apps.streamAppActivity({
  appId,
  afterSeq: -1n, // bigint: live-only; pass your last acked seq to catch up
})) {
  switch (event.payload.case) {
    case "activity":
      ingest(event.payload.value.records);
      break;
    case "presence":
      setPresence(event.payload.value.members);
      break;
    // "heartbeat": keepalive
  }
}