Код: Выделить всё
FindPublisher registrationPublisher = registrationCollection.find();
Flux.from(registrationPublisher).flatMap(registration -> {
Bson filter = Filters.eq("registrationId", registration.id().toString());
return Flux.from(bindingCollection.find(filter)).flatMap(b -> {...});
}).subscribe();
В один и тот же момент, если я подписывается () перед Blockfirst ()
Подробнее здесь: https://stackoverflow.com/questions/796 ... or-mongodb