Hierarchy
-
PersistedEntityReduceProjection
Constructors
constructor
-
Parameters
-
-
-
Default value eventFilter: function = (e) => true
-
-
Parameters
Returns boolean
Properties
Private eventFilter
eventFilter: function
Type declaration
-
-
Parameters
Returns boolean
Methods
getState
- getState(id: string): Promise<T>
-
Parameters
Returns Promise<T>
handleEvent
- handleEvent(event: Event): Promise<void>
-
Parameters
Returns Promise<void>
rebuildStream
- rebuildStream(): Writable
A projection that stores a state for each entity in its storage.
const projection = new PersistedEntityReduceProjection(catFedReducer, storage); bus.onEvent((event) => projection.handleEvent(event)); const felixFed = await projection.getState("felix");