Skip to main content

DomainEventQueues

Index

Constructors

constructor

Methods

enqueue

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

    Returns void

forEach

drainQueueFor

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

    • sceneId: CorrelationId

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