Connectum API Reference / @connectum/events / BroadcastSubscribersOptions

Interface: BroadcastSubscribersOptions

Defined in: packages/events/src/broadcast.ts:33

Options for createBroadcastSubscribers.

Properties

adapter

readonly adapter: EventAdapter | EventAdapterFactory

Defined in: packages/events/src/broadcast.ts:40

The broker adapter. Pass ONE shared instance (fine for MemoryAdapter in tests, where all buses share the in-memory registry) OR a factory invoked once per reactor (use this for real brokers so each reactor bus gets its own connection / durable consumer).

---

drainPublishTimeout?

readonly optional drainPublishTimeout?: number

Defined in: packages/events/src/broadcast.ts:48

Shared per-bus opt-in publish drain budget at stop() (ms). Since 1.3.0.

---

drainTimeout?

readonly optional drainTimeout?: number

Defined in: packages/events/src/broadcast.ts:46

Shared per-bus drain timeout (ms).

---

handlerTimeout?

readonly optional handlerTimeout?: number

Defined in: packages/events/src/broadcast.ts:44

Shared per-bus handler timeout (ms).

---

reactors

readonly reactors: BroadcastReactor[]

Defined in: packages/events/src/broadcast.ts:42

The independent reactors — each becomes its own EventBus with its own group.

---

signal?

readonly optional signal?: AbortSignal

Defined in: packages/events/src/broadcast.ts:50

Shared abort signal for graceful shutdown.