onErrorMapBatchTaskException

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