toDomainEventStream
fun Any.toDomainEventStream(upstream: CommandMessage<*>, aggregateVersion: Int, stateOwnerId: String = OwnerId.DEFAULT_OWNER_ID, header: Header = DefaultHeader.empty(), createTime: Long = System.currentTimeMillis()): DomainEventStream