compensate

abstract fun compensate(eventStream: E, target: CompensationTarget): Mono<Void>

open fun compensate(aggregateId: AggregateId, version: Int, target: CompensationTarget): Mono<Long>