Class EventBus

Provide handling for an event based system

Hierarchy

EventBus

Index

Constructors

Properties

_distributor _explorer _handlerMap _observableFactory _sagaManager _status commandBus eventSource pubSub

Methods

executeLocal listen listenLocal onApplicationBootstrap publish removeListener removeLocalListener

Constructors

constructor

new EventBus(commandBus: CommandBus, _explorer: Explorer, _observableFactory: ObservableFactory, _sagaManager: SagaManager, eventSource: IEventSource, pubSub: IPubSub): EventBus
Parameters
- commandBus: CommandBus
- _explorer: Explorer
- _observableFactory: ObservableFactory
- _sagaManager: SagaManager
- eventSource: IEventSource
- pubSub: IPubSub
Returns EventBus
- Defined in moirae/core/lib/busses/event.bus.ts:30

Properties

`Private` `Readonly` _distributor

_distributor: Distributor<IEvent<unknown>>

`Private` `Readonly` _explorer

_explorer: Explorer

`Private` `Readonly` _handlerMap

_handlerMap: Map<string, IEventHandler<IEvent<unknown>>[]>

`Private` `Readonly` _observableFactory

_observableFactory: ObservableFactory

`Private` `Readonly` _sagaManager

_sagaManager: SagaManager

`Private` _status

_status: StateTracker<ESState>

`Private` `Readonly` commandBus

commandBus: CommandBus

`Private` `Readonly` eventSource

eventSource: IEventSource

`Private` `Readonly` pubSub

pubSub: IPubSub

Methods

`Protected` executeLocal

executeLocal(event: IEvent<unknown>): Promise<void>
Parameters
- event: IEvent<unknown>
Returns Promise<void>
- Defined in moirae/core/lib/busses/event.bus.ts:47

listen

listen(handlerFn: ((event: IEvent<unknown>) => void)): string
Listen to events post-processing, including those processed locally
Parameters
- handlerFn: ((event: IEvent<unknown>) => void)
  - - (event: IEvent<unknown>): void
    - Parameters
      
      event: IEvent<unknown>
      
      Returns void
Returns string
- Defined in moirae/core/lib/busses/event.bus.ts:76

listenLocal

listenLocal(handlerFn: ((event: IEvent<unknown>) => void)): string
Listen to events processed locally
Parameters
- handlerFn: ((event: IEvent<unknown>) => void)
  - - (event: IEvent<unknown>): void
    - Parameters
      
      event: IEvent<unknown>
      
      Returns void
Returns string
- Defined in moirae/core/lib/busses/event.bus.ts:83

onApplicationBootstrap

onApplicationBootstrap(): void
Returns void
- Defined in moirae/core/lib/busses/event.bus.ts:87

publish

publish(event: IEvent<unknown>): Promise<void>
Parameters
- event: IEvent<unknown>
Returns Promise<void>
- Defined in moirae/core/lib/busses/event.bus.ts:105

removeListener

removeListener(subId: string): void
Unsubscribe to events post-processing
Parameters
- subId: string
Returns void
- Defined in moirae/core/lib/busses/event.bus.ts:112

removeLocalListener

removeLocalListener(subId: string): void
Unsubscribe to locally processed events
Parameters
- subId: string
Returns void
- Defined in moirae/core/lib/busses/event.bus.ts:119

Generated using TypeDoc