रिएक्टर जावा फ्लक्स बनाम मोनो

मेरे पास लागू करने के लिए निम्नलिखित परिदृश्य है। उपयोगकर्ता आईडी द्वारा नौकरियों की सूची प्राप्त करें, नौकरियों को पुनरावृत्त करें और फिर विशेषता द्वारा खाता प्रविष्टि प्राप्त करें और अंत में खाते में अपडेट करें।

विधि परिभाषा

Mono<Void> execute(List<String> users)

जॉब्स दाओ मोनो लौटा रहा है<सूची>

Mono<List<JobInfo>> getJobsByUser(String user)

class JobInfo {
   String user;
   String account;
}

खाता प्राप्त करना मोनो सूची लौटा रहा है,

Mono<List<Account>> getAccounts(String account)

मैं मोनो नो ब्लॉकिंग तरीके का उपयोग करके ऐसा करने के लिए संघर्ष कर रहा हूं। मैंने ब्लॉक का उपयोग करके ऐसा करने की कोशिश की लेकिन हो रही है

block()/blockFirst()/blockLast() are blocking, which is not supported in thread reactor-http-nio-

public Mono<Void> execute(List<String> users) {
   users.forEach(user -> {
    jobDao.getJobsByUser(user).block().stream().forEach(job -> {
      accountDam.getAccounts(job.getAccount()).block().forEach(acc -> {
        // update account
      });
    });
   
   });

   return Mono.empty().then();

}