React器内通量过滤器

v2g6jxz6 于 2021-07-03 发布在 Java

关注(0)|答案(1)|浏览(312)

假设我有一个 Flux<O> 我想过滤掉其中的一些，但这需要另一个的结果 Flux ，不知道怎么做。
例如

private Mono<Boolean> somePredicate(int num) {
   // logic
   return Mono.just(true);
}

Flux<O> flux = Flux.just(1, 2, 3, 4, ...);
flux.filter(n -> somePredicate(n));    // I know it is not right here, but could not figure out

Java reactive reactor r2dbc

来源：https://stackoverflow.com/questions/65067530/java-reactor-flux-filter-with-inner-flux

1条答案

按热度按时间

vom3gejh1#

在以下情况下，可以使用过滤器异步测试通量发出的每个值：

Flux.just( 1, 2, 3, 4).filterWhen( this::somePredicate );

赞(0）回复(0）举报 2021-07-03

我来回答

React器内通量过滤器

1条答案

相关问题

热门标签

最新问答