toBatchResult

fun Flux<AggregateId>.toBatchResult(afterId: String): Mono<BatchResult>