MockDomainEventStreams

Functions

Link copied to clipboard
fun generateEventStream(aggregateId: AggregateId, aggregateVersion: Int = DEFAULT_AGGREGATE_VERSION, eventCount: Int = DEFAULT_EVENT_COUNT, createdEventSupplier: (AggregateId) -> Any = { _ -> MockAggregateCreated(GlobalIdGenerator.generateAsString()) }, changedEventSupplier: (AggregateId) -> Any = { _ -> MockAggregateChanged(GlobalIdGenerator.generateAsString()) }): DomainEventStream