DomainEventQueue

Index

Constructors

• constructor

Accessors

• sceneId

Methods

• first
• enqueue
• drain
• reduce

Constructors

constructor

• new DomainEventQueue(...items: (DomainEvent & { sceneId: CorrelationId })[]): DomainEventQueue

• Parameters

  • rest...items: (DomainEvent & { sceneId: CorrelationId })[]

  Returns DomainEventQueue

Accessors

sceneId

• get sceneId(): CorrelationId

• Returns CorrelationId

Methods

first

• first(): DomainEvent & { sceneId: CorrelationId }

• Returns DomainEvent & { sceneId: CorrelationId }

enqueue

• enqueue(event: DomainEvent & { sceneId: CorrelationId }): void

• Parameters

  • event: DomainEvent & { sceneId: CorrelationId }

  Returns void

drain

• drain(): (DomainEvent & { sceneId: CorrelationId })[]

• Returns (DomainEvent & { sceneId: CorrelationId })[]

reduce

• reduce<U>(fn: (previousValue: U, currentValue: DomainEvent & { sceneId: CorrelationId }, currentIndex: number) => U, initialValue: U): U

• Type parameters

  • U

  Parameters

  • fn: (previousValue: U, currentValue: DomainEvent & { sceneId: CorrelationId }, currentIndex: number) => U

  • initialValue: U

  Returns U