Mono / Flux是否具有Stream API中的Peek / IfPresent这样的运算符？

Question

正如标题所述，想知道在使用Mono / Flux时是否有任何等效（或类似的）运算符可以窥视，而Java Stream API是否包含ifPresent。

Answer 1

Flux#hasElement：

如果此Flux序列的任何元素等于提供的值，则发出一个布尔布尔值true。该实现使用短路逻辑，如果元素匹配该值，则以true结束。

Mono<Boolean> ifPresent = Flux.<Ob>just(...)
        .hasElement(value); // similar to ifPresent

Flux#doOnNext：

当助焊剂发射物品时触发添加行为（副作用）。>>

Flux<Ob> flux = Flux.<Ob>just()
        .doOnNext(i -> {}); // similar to peek