如何对流量进行异步过滤

我需要检查该店的标题或库存中是否包含子字符串。

 @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 
                                });

          });
}

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

---

解决方案

查看Flux#filter运算符签名：

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

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

您可以改用filterWhen运算符：

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