Class MemoryEventBus

In-memory bus connection.

Records every emitted message on events instead of hitting a real transport. Useful in tests and local development to assert what would have been published.

Implements

EventBusConnection

Index

Constructors

Properties

Methods

Constructors

constructor

new MemoryEventBus(name?: string): MemoryEventBus
Parameters
- name: string = 'memory'
  The connection name.
Returns MemoryEventBus

Properties

`Readonly`events

events: BusMessage<unknown>[] = []

The messages emitted so far, in order.

`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(name?: string): MemoryEventBus
Create a memory connection.
Parameters
- name: string = 'memory'
  The connection name.
Returns MemoryEventBus
A new connection.