Options
All
  • Public
  • Public/Protected
  • All
Menu

Class ProjectionWorker

Hierarchy

  • ProjectionWorker

Index

Constructors

constructor

Properties

Private addToQueueWaitResolvers

addToQueueWaitResolvers: Array<function> = []

Private maxQueueSize

maxQueueSize: number

projection

projection: Projection

Private queue

queue: Set<EventWithMetadata>

Private workerLoopRunning

workerLoopRunning: boolean = false

Methods

addToQueue

Private workerLoop

  • workerLoop(): Promise<void>

Generated using TypeDoc