Search
Preparing search index...
The search index is not available
ddes
Options
All
Public
Public/Protected
All
Inherited
Externals
Only exported
Menu
Packages
@ddes/core
ProjectionWorker
Class ProjectionWorker
Hierarchy
ProjectionWorker
Index
Constructors
constructor
Properties
add
ToQueue
Wait
Resolvers
max
Queue
Size
projection
queue
worker
Loop
Running
Methods
add
ToQueue
worker
Loop
Constructors
constructor
new
Projection
Worker
(
params
:
object
)
:
ProjectionWorker
Parameters
params:
object
max
Queue
Size
:
number
projection
:
Projection
Returns
ProjectionWorker
Properties
Private
add
ToQueue
Wait
Resolvers
add
ToQueue
Wait
Resolvers
:
Array
<
function
>
= []
Private
max
Queue
Size
max
Queue
Size
:
number
projection
projection
:
Projection
Private
queue
queue
:
Set
<
EventWithMetadata
>
Private
worker
Loop
Running
worker
Loop
Running
:
boolean
= false
Methods
add
ToQueue
add
ToQueue
(
eventWithMetadata
:
EventWithMetadata
)
:
Promise
<
void
>
Parameters
eventWithMetadata:
EventWithMetadata
Returns
Promise
<
void
>
Private
worker
Loop
worker
Loop
(
)
:
Promise
<
void
>
Returns
Promise
<
void
>
Packages
@ddes/aws-
lambda-
transformer
@ddes/aws-
store
@ddes/cli
@ddes/core
@ddes/event-
streaming
@ddes/store-
transformations
Aggregate
Already
Committing
Error
Batch
Mutator
Commit
Event
Store
Key
Schema
Meta
Store
Projection
Projection
Worker
constructor
add
ToQueue
Wait
Resolvers
max
Queue
Size
projection
queue
worker
Loop
Running
add
ToQueue
worker
Loop
Projector
Snapshot
Store
Store
Poller
Version
Conflict
Error
Aggregate
Event
Upcasters
Aggregate
Snapshot
Event
Hydrate
Options
Key
Schema
Property
Projection
Params
Retry
Config
Store
Poller
Params
Store
Query
Response
Store
Query
Result
Set
Aggregate
Key
Aggregate
Key
Props
Aggregate
Type
Event
Input
Event
With
Metadata
Internal
State
Marshalled
Commit
Meta
Store
Key
Store
Cursor
Timestamp
retry
Command
upcast
Commits
Generated using
TypeDoc