Class AggregateFactory

Hierarchy

AggregateFactory

Index

Constructors

Properties

cache eventSource

Methods

commitEvents mergeContext

Constructors

constructor

new AggregateFactory(cache: ICache, eventSource: IEventSource): AggregateFactory
Parameters
- cache: ICache
- eventSource: IEventSource
Returns AggregateFactory
- Defined in moirae/core/lib/factories/aggregate.factory.ts:11

Properties

`Private` `Readonly` cache

cache: ICache

`Private` `Readonly` eventSource

eventSource: IEventSource

Methods

commitEvents

commitEvents(events: IEvent<unknown>[]): Promise<IEvent<unknown>[]>
Parameters
- events: IEvent<unknown>[]
Returns Promise<IEvent<unknown>[]>
- Defined in moirae/core/lib/factories/aggregate.factory.ts:16

mergeContext

mergeContext<TAgg>(streamId: string, Aggregate: ClassConstructor<TAgg>): Promise<TAgg>
Initialize a new instance of an aggregate based on the aggregate type and streamId. Will read the event store for all events matching the parameters and apply them to the aggregate in order.
Type Parameters
- TAgg extends AggregateRoot<unknown, TAgg>
Parameters
- streamId: string
- Aggregate: ClassConstructor<TAgg>
  
  Constructor for the aggregate
Returns Promise<TAgg>
- Defined in moirae/core/lib/factories/aggregate.factory.ts:28

Generated using TypeDoc