upstream

abstract fun upstream(upstream: DomainEvent<*>): CommandBuilder
abstract val upstream: DomainEvent<*>?