Объедините несколько моно в Spring Webflux - PullRequest
Новая
       45

Объедините несколько моно в Spring Webflux

2 голосов
/ 28 апреля 2020

Я новичок в webflux и пытаюсь выполнить несколько моно с Flux. Но я думаю, что я делаю это неправильно ... это лучший способ выполнить несколько Mono и собрать их в список?

Вот мой код: 

    mainService.getAllBranch()
            .flatMapMany(branchesList -> {
                List<Branch> branchesList2 = (List<Branch>) branchesList.getData();
                List<Mono<Transaction>> trxMonoList= new ArrayList<>();

                branchesList2.stream().forEach(branch -> {
                    trxMonoList.add(mainService.getAllTrxByBranchId(branch.branchId));
                });
                return Flux.concat(trxMonoList); // <--- is there any other way than using concat?
            })
            .collectList()
            .flatMap(resultList -> combineAllList());

    interface MainService{
            Mono<RespBody> getAllBranch();
            Mono<RespBody> getAllTrxByBranchId(String branchId); //will return executed url ex: http://trx.com/{branchId}
    }

пока что мой код выше, я могу объяснить это так:

  1. Получить все ветви
  2. перебрать все branchesList2 и добавить его к trxMonoList
  3. return Flux.concat, я не уверен, что это правильный путь или нет. но он работает
  4. объединить весь список

Я просто запутался, это правильный способ использования Flux в моем контексте? или есть какой-то лучший способ добиться того, что я пытаюсь сделать?

Ответы [ 2 ]

2 голосов
/ 28 апреля 2020

Настоящая проблема здесь в том, что вы не должны нажимать Mono несколько раз в пределах Flux. Это даст вам проблемы. Если вы разрабатываете API, вы должны исправить это, чтобы сделать то, что вы хотите, в правильной реактивной манере. 

interface MainService{
        Flux<Branch> getAllBranch();
        Flux<Transaction> getAllTrxByBranchId(Flux<String> branchIds);
}

Тогда ваш код станет проще, и реактивная структура будет работать правильно. 

mainService.getAllTrxByBranchId(mainService.getAllBranch().map(Branch::getId));
2 голосов
/ 28 апреля 2020

Вам нужно немного изменить свой код на реактивный. 

 mainService.getAllBranch()
        .flatMapMany(branchesList -> Flux.fromIterable(branchesList.getData())) (1)
        .flatMap(branch -> mainService.getAllTrxByBranchId(branch.branchId))    (2)
        .collectList()
        .flatMap(resultList -> combineAllList());

1) Создать Поток веток из Списка;

2) Итерация по каждому элементу и вызов службы.

Вы не должны не используйте Stream API в Reactor, потому что он имеет те же методы, но с адаптацией и оптимизацией для многопоточности.

...