Real-time Patterns

import { useAgentStream } from "@/hooks/useAgentStream";

const { chunks, status, latency, start, reset } = useAgentStream({
  content: "Your agent response text here...",
  chunkInterval: 40,   // ms between chunks
  chunkSize: 3,        // chars per chunk
  ttft: 320,           // simulated time-to-first-token
});

// chunks: string[]        — accumulated text pieces
// status: StreamStatus    — "idle" | "streaming" | "complete" | "error"
// latency: number | null  — ms to first token

import { usePositionFeed } from "@/hooks/usePositionFeed";

const { positions, lastUpdate, delta, running, pause, resume } = usePositionFeed({
  interval: 1500,     // tick frequency in ms
  volatility: 0.3,   // 0=frozen, 1=very volatile
});

// positions:  Position[]    — current live book
// lastUpdate: Date | null   — timestamp of last tick
// delta:      PositionDelta[] — rateDelta + pnlDelta per pair since last tick

import { useAgentHeartbeat } from "@/hooks/useAgentHeartbeat";

const { agents, lastPing, stale, ping } = useAgentHeartbeat({
  interval: 3000,       // poll frequency in ms
  staleAfterMs: 8000,   // threshold before marking agent stale
});

// agents:   AgentRecord[]  — array with { id, name, role, status, lastSeenMs, currentTask }
// lastPing: Date | null    — when the last poll completed
// stale:    boolean        — true if ANY agent is stale or offline
// ping:     () => void     — force an immediate poll

Related