Interface IPubSub

Pub-sub engine to distribute events across the system after processing on a single node.

Hierarchy

IPubSub

Index

Methods

publish subscribe unsubscribe

Methods

publish

publish(event: IEvent<unknown>): Promise<void>
Distribute an event to the system
Parameters
- event: IEvent<unknown>
Returns Promise<void>
- Defined in moirae/core/lib/interfaces/pub-sub.interface.ts:11

subscribe

subscribe(handler: ((event: IEvent<unknown>) => void)): string
Subscribe to the event distribution and handle

Returns
Subscription ID
Parameters
- handler: ((event: IEvent<unknown>) => void)
  - - (event: IEvent<unknown>): void
    - Parameters
      
      event: IEvent<unknown>
      
      Returns void
Returns string
- Defined in moirae/core/lib/interfaces/pub-sub.interface.ts:16

unsubscribe

unsubscribe(key: string): void
Unsubscribe to the event stream
Parameters
- key: string
Returns void
- Defined in moirae/core/lib/interfaces/pub-sub.interface.ts:20

Generated using TypeDoc