generateEventStream
fun generateEventStream( aggregateId: AggregateId, aggregateVersion: Int = DEFAULT_AGGREGATE_VERSION, eventCount: Int = DEFAULT_EVENT_COUNT, ownerId: String = OwnerId.DEFAULT_OWNER_ID, createdEventSupplier: (AggregateId) -> Any = { _ -> MockAggregateCreated(generateGlobalId()) }, changedEventSupplier: (AggregateId) -> Any = { _ -> MockAggregateChanged(generateGlobalId()) }): DomainEventStream