Class EventBus

A simple in-memory event bus.

Index

Constructors

Methods

getEvents publish subscribe

Constructors

constructor

new EventBus(options?: { cacheSize?: number; log?: Log }): EventBus
Creates an event bus with options.
Parameters
- options: { cacheSize?: number; log?: Log } = {}
  - OptionalcacheSize?: number
    Number of cached last events.
  - Optionallog?: Log
    Logger, default is the console.
Returns EventBus
- Defined in src/infrastructure/event_bus.ts:23

Methods

getEvents

getEvents(): Readonly<{ data: unknown; type: string }>[]
Return the cached events.

Returns Readonly<{ data: unknown; type: string }>[]
- Defined in src/infrastructure/event_bus.ts:71

publish

publish(event: Message): void
Publish an event to all handlers.
Parameters
- event: Message
Returns void
- Defined in src/infrastructure/event_bus.ts:49

subscribe<TMessage extends Readonly<{ data: unknown; type: string }>>(
handler: MessageHandler<TMessage, void>,
): () => void
Subscribe a handler to all events.
Type Parameters
- TMessage extends Readonly<{ data: unknown; type: string }>
Parameters
- handler: MessageHandler<TMessage, void>
Returns () => void
Unsubscribe function.
- Defined in src/infrastructure/event_bus.ts:36