本文介紹了如何對流量進行異步過濾的處理方法，對大家解決問題具有一定的參考價值，需要的朋友們下面隨著小編來一起學習吧！
問題描述
我需要檢查該店的標題或庫存中是否包含子字符串。
@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中的子字符串內(nèi)容時，對我來說出現(xiàn)一次就足夠了。
推薦答案
查看Flux#filter運算符簽名：
Flux<T> filter(Predicate<? super T> p)
我們看到它接受一個簡單的Java謂詞作為參數(shù)。您不能在其中執(zhí)行異步操作。
您可以改用filterWhen運算符：
shopRepo.findAll()
.filterWhen(shop ->
(shop condition) ? Mono.just(true) :
stockService.findStocksByShopId(shop.getId())
.map(stock -> (stock condition)))
這篇關于如何對流量進行異步過濾的文章就介紹到這了，希望我們推薦的答案對大家有所幫助，
