如何异步过滤 Flux答案

【问题标题】：How to filter Flux asynchronously如何异步过滤 Flux
【发布时间】：2021-11-30 11:29:39
【问题描述】：

我需要检查一个子字符串是否包含在该商店的商店或股票的标题中。

 @Override
    public Flux<Shop> searchShopsBySearchingTextInShopsAndStocks(String searchText) {

// I received Flxux<List<Shop>> 
 return shopRepo.findAll().
   // next I check if substring in title of shop
   filter(shop -> {
         if (shop.getTitle().contains(searchText) || shop.getDescription().contains(searchText)) {
                                            
                       // if contains then return TRUE if not check in stocks
                        return true;
                    } else {
                                 // reeived all stock Flux<List<Stock>> of this shop and check
                          return stockService.findStocksByShopId(shop.getId()).
                                flatMap(stock -> {
                                    if (stock.getDescription().contains(searchText) || stock.getTitle().contains(searchText)) {

           // and in this place I need help

                                        return  // true
                                    }

                                    return //false 
                                });

          });
}

在检查股票中子字符串的内容时，对我来说出现一次就足够了。

【问题讨论】：

标签： java spring-webflux project-reactor

【解决方案1】：

看Flux#filter操作符签名：

Flux<T> filter(Predicate<? super T> p)

我们看到它接受一个简单的 Java Predicate 作为参数。您不能在其中执行异步操作。

您可以改用filterWhen 运算符：

shopRepo.findAll()  
    .filterWhen(shop ->
        (shop condition) ? Mono.just(true) :
                stockService.findStocksByShopId(shop.getId())
                        .map(stock -> (stock condition)))

【讨论】：