Прежде чем продолжить, удалите все элементы из флюса. ⇐ JAVA

[Anonymous]

Мне нужно убедиться, что все операции со всеми элементами пользователя завершены, прежде чем что-то делать с записью пользователя. Перед тем как продолжить, сокращение ожидает всех элементов из FlatMap? Если нет, то как я могу это сделать?
Flux.fromIterable(userIds)
// each element has multiple userIds
.flatMap(
userId -> getUserItems(userId)
.map(userItemIds -> doSomethingWithUserItemRecord(userId,userItemIds)))
.reduce(new Result(0, true), this::mergeResult)
// batch operations on all userIds in an element from the original source
.map(result-> doSomethingWithUsersRecords(result))


Подробнее здесь: https://stackoverflow.com/questions/789 ... proceeding