@lesto/pubsub

Lesto's pub/sub + transport-neutral WebSocket fan-out core: an in-process hub, the fanout() send policy (with backpressure), a bounded replay-ring eviction helper, and signed per-channel capability tokens.

Part of Lesto, the batteries-included, agent-native fullstack framework.

bun add @lesto/pubsub

import { PubSub } from "@lesto/pubsub";

const hub = new PubSub();
const off = hub.subscribe("orders", (message, channel) => {
  /* … */
});
await hub.publish("orders", { id: 1 });
off();

In-process only (one process). For cross-process fan-out, pair it with @lesto/realtime.

Maturity: v0.

Docs · Example