onErrorMapBatchTaskException

fun <T> Mono<T>.onErrorMapBatchTaskException(aggregateId: AggregateId): Mono<T>