toDomainEventStream

fun Any.toDomainEventStream(upstream: CommandMessage<*>, aggregateVersion: Int, header: Header = DefaultHeader.empty()): DomainEventStream