@lesto/realtime
v0.1.7
Published
Lesto's realtime transport (ADR 0040) — the cross-process topic bus + SSE fan-out behind the in-process @lesto/pubsub hub. This package holds the pure cores: the resume-cursor replay ring and the transport seam.
Downloads
753
Readme
@lesto/realtime
The cross-process topic bus + SSE fan-out behind @lesto/pubsub (ADR 0040).
Part of Lesto, the batteries-included, agent-native fullstack framework.
bun add @lesto/realtimeimport { createRealtimeBus, PostgresTransport, createRealtimeHttpHandlers } from "@lesto/realtime";
const bus = createRealtimeBus({ transport: new PostgresTransport(/* … */) });
const handlers = createRealtimeHttpHandlers(bus); // mounts GET /__lesto/live (SSE)Carries invalidation topics, never row data (the ADR 0027 invariant). Ships
the pure cores — a resume-cursor replay ring and the transport seam (Postgres
LISTEN/NOTIFY) — behind the in-process @lesto/pubsub hub.
Maturity: v0, evolving alongside ADR 0027's live useQuery.
