Flux.all 使用说明书

all

public final Mono<Boolean> all(Predicate<? super T> predicate)

Emit a single boolean true if all values of this sequence match the Predicate.

如果该序列中的所有值都匹配给定的谓词（Predicate），则发出一个布尔值 true。

The implementation uses short-circuit logic and completes with false if the predicate doesn't match a value.

该实现使用短路逻辑，如果谓词未匹配到某个值，则以 false 完成。

Parameters:

predicate - the Predicate that needs to apply to all emitted items

Returns:

a new Mono with true if all values satisfies a predicate and false otherwise

参数：

predicate - 需要应用于所有发出项的谓词（Predicate）

返回值：

一个新的 Mono，如果所有值都满足谓词，则返回 true，否则返回 false。

all 方法是 Reactor 中用于对 Flux 或 Mono 中的元素进行判断的一个操作符，它会对流中的每个元素应用提供的 Predicate（断言）函数，并返回一个新的 Mono<Boolean>。它用于检查流中是否所有元素都符合给定的条件。

如果所有元素都满足条件，则返回 Mono.just(true)，否则返回 Mono.just(false)。

方法定义

javapublic final Mono<Boolean> all(Predicate<? super T> predicate)

Predicate<? super T> predicate：传入的断言函数，它接收流中的每个元素，并返回 true 或 false。断言函数用于定义某个元素是否符合条件。
返回值：一个 Mono<Boolean>，表示所有元素是否都符合断言。

工作原理

all 方法会遍历 Flux 或 Mono 中的每个元素，并应用传入的断言函数。
如果流中每个元素都符合断言，即断言返回 true，那么 all 方法最终会返回 Mono.just(true)。
如果某个元素不符合断言（即断言返回 false），则会立即返回 Mono.just(false)，不再检查剩下的元素。
如果流是空的，默认返回 true，因为没有元素意味着“所有元素”自然满足条件。

示例

假设我们有一个 Flux，它包含了一组整数，并且我们想判断这些整数是否都是偶数：

javaFlux<Integer> numbers = Flux.just(2, 4, 6, 8);// 使用 all 操作符判断所有元素是否是偶数
Mono<Boolean> allEven = numbers.all(number -> number % 2 == 0);allEven.subscribe(result -> System.out.println("All numbers are even: " + result));

输出：

All numbers are even: true

在这个例子中：

numbers 是一个包含 2, 4, 6, 8 的 Flux。
我们通过 all 方法传递了一个断言函数：number -> number % 2 == 0，这个断言会检查每个数字是否是偶数。
因为所有的数字都是偶数，所以最终返回 Mono.just(true)。

再看一个不同的例子，如果我们有一个元素不满足条件：

javaFlux<Integer> numbers = Flux.just(2, 4, 5, 8);// 使用 all 操作符判断所有元素是否是偶数
Mono<Boolean> allEven = numbers.all(number -> number % 2 == 0);allEven.subscribe(result -> System.out.println("All numbers are even: " + result));

输出：

All numbers are even: false

在这个例子中：

因为数字 5 不符合偶数条件，all 方法会立即返回 Mono.just(false)。

空流的情况

如果流是空的，all 会直接返回 Mono.just(true)。因为没有元素存在，也就不存在不符合条件的元素。

javaFlux<Integer> emptyFlux = Flux.empty();// 使用 all 操作符判断空流是否满足条件
Mono<Boolean> result = emptyFlux.all(number -> number % 2 == 0);result.subscribe(System.out::println);