Class LocalEventBus

In-process bus connection.

Delivers to the application's own EventEmitter, so the same emit code reaches in-process listeners in a monolith. The emitter is used, never modified: the core stays untouched.

Implements

EventBusConnection

Index

Constructors

Properties

Methods

Constructors

constructor

new LocalEventBus(emitter: EmitterLike, name?: string): LocalEventBus
Parameters
- emitter: EmitterLike
  The application event emitter.
- name: string = LOCAL
  The connection name.
Returns LocalEventBus

Properties

`Readonly`name

name: string

A human-readable name (e.g. local, cloud, eventbridge).

Methods

emit

emit<T = unknown>(name: string, payload?: T): Promise<void>
Type Parameters
- T = unknown
Parameters
- name: string
- Optionalpayload: T
Returns Promise<void>

Inherit Doc

Implementation of EventBusConnection.emit

`Static`create

create(emitter: EmitterLike, name?: string): LocalEventBus
Create a local connection.
Parameters
- emitter: EmitterLike
  The application event emitter.
- name: string = LOCAL
  The connection name.
Returns LocalEventBus
A new connection.