Как конвертировать вложенный список в Mono в Flux?

Question

Я очень новичок в реактивных потоках, Может кто-нибудь помочь мне преобразовать Mono<MyClass> в Flux<Integer>

Я пробовал что-то вроде этого -

Flux<Integer> myMethod(Mono<MyClass> homeWork) {
    return homeWork.map(h -> h.multiplicands)
              .flatMapMany(Flux::fromIterable).map(m -> h*m);
}

public class MyClass{
    int multiplier;
    List<Integer> multiplicands;
}

Я ожидаю результата умножения * (каждого) множителя в формате Flux<Integer>.

Можете ли вы помочь мне с правильным способом сделать это?

Answer 1

Преобразуйте экземпляр MyClass в Stream<Integer>, который содержит умноженные целые числа, а затем превратите Mono<Stream<Integer>> в Flux<Integer>:

Flux<Integer> myMethod(Mono<MyClass> homeWork) {
  return homeWork
           .map(hw -> hw.multiplicands.stream().map(m -> m * hw.multiplier))
           .flatMapMany(Flux::fromStream);
}