Class EventEmitterStream

The EventStream interface implements a pub/sub system based on Message filters.

Implements

EventStream

Index

Constructors

Methods

close emit open subscribe

Constructors

constructor

new EventEmitterStream(config?): EventEmitterStream
Parameters
- config: EventEmitterStreamConfig = {}
Returns EventEmitterStream
- Defined in src/event-log/event-emitter-stream.ts:21

Methods

close

close(): Promise<void>
Returns Promise<void>
Implementation of EventStream.close
- Defined in src/event-log/event-emitter-stream.ts:54

emit

emit(tenant, event, indexes): void
Parameters
- tenant: string
- event: MessageEvent
- indexes: KeyValues
Returns void
Implementation of EventStream.emit
- Defined in src/event-log/event-emitter-stream.ts:59

open

open(): Promise<void>
Returns Promise<void>
Implementation of EventStream.open
- Defined in src/event-log/event-emitter-stream.ts:50

subscribe

subscribe(tenant, id, listener): Promise<EventSubscription>
Parameters
- tenant: string
- id: string
- listener: EventListener
Returns Promise<EventSubscription>
Implementation of EventStream.subscribe
- Defined in src/event-log/event-emitter-stream.ts:42