Mono/Flux 是否有来自 Stream/Optional 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 发出项目时触发的行为（副作用）。

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