相关疑难解决方法(0)

I have a use case when I should send email to the users. First I create email body.

Mono<String> emailBody = ...cache();

And then I select users and send the email to them:

Flux.fromIterable(userRepository.findAllByRole(Role.USER))
            .map(User::getEmail)
            .doOnNext(email -> sendEmail(email, emailBody.block(), massSendingSubject))
            .subscribe();

What I don't like

1. Without cache() method emailBody Mono calculates in each iteration step.
2. To get emailBody value I use emailBody.block() but maybe there's a reactive way and not call block method inside Flux flow?