在迭代Flux代码时,方法结束时出现问题。

我尝试了所有可能,但没有运气

    Flux ItemInventoryModelFlux = InventoryService .findBIdAndListOfItems(storeId, itemList);
    Mono<Object> obj = storeItemInventoryModelFlux.collectList().flatMap(storeItemInventoryModels -> {
      response.getAdjustedDemand().stream().forEach(adjustedDemand -> {
        if (bpnList.contains(adjustedDemand.getBpn())) {
          if (true) {
            storeItemInventoryModels.stream().forEach(storeItemInventoryModel -> {
              isRegularItem(storeItemModelFlux,bpnList.get(0));
            });
          }
        }
      });


这应该在循环内运行到其他方法,但要结束。

最佳答案

使用Flux<T> takeWhile(Predicate<? super T> continuePredicate)函数指定“退出”条件。当您提供的谓词返回false时,您将停止使用原始流中的元素。
Link to Flux javadoc

09-26 11:39