Does Mono/Flux have operators like Peek / IfPresent from the Stream / Optional API?

user_11971373 0
Viewed 4949

As title says, was wondering if, when working with Mono/Flux, are there any equivalent (or similar) operators to peek and ifPresent from the Java Stream API.

project-reactor java-stream spring-webflux java
1 Answers

Flux#hasElement:

Emit a single boolean true if any of the elements of this Flux sequence is equal to the provided value. The implementation uses short-circuit logic and completes with true if an element matches the value.

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

Flux#doOnNext:

Add behavior (side-effect) triggered when the Flux emits an item.

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