interface EventStream { close(): Promise<void>; emit(tenant,
event,
indexes): void; open(): Promise<void>; subscribe(tenant,
id,
listener): Promise<EventSubscription>; } Methods
close
- close(): Promise<void>
Returns Promise<void>
emit
- emit(tenant, event, indexes): void
Returns void
open
- open(): Promise<void>
Returns Promise<void>
subscribe
- subscribe(tenant, id, listener): Promise<EventSubscription>
Parameters
- tenant: string
- id: string
- listener: EventListener
Returns Promise<EventSubscription>
The EventStream interface implements a pub/sub system based on Message filters.