Appearance

Connectum API Reference / @connectum/events / BroadcastSubscribersOptions

Interface: BroadcastSubscribersOptions ​

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

Options for createBroadcastSubscribers.

Properties ​

adapter ​

readonly adapter: EventAdapter | (() => EventAdapter)

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).

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:48

Shared abort signal for graceful shutdown.