如何对 StepVerifier 中的所有剩余元素执行断言？

Question

StepVerifier 有一个assertNext方法允许对下一个元素的值执行断言。

    StepVerifier.create(dataFlux)
            .assertNext(v -> checkValue(v)
            .verifyComplete();

对每个剩余元素执行断言的好方法是什么（例如检查每个元素是否为正）？我希望有类似assertEveryNextElement方法的东西。

Answer 1

我第一次尝试对通量的所有元素进行断言是

StepVerifier.create(dataFlux)
        .recordWith(ArrayList::new)
        .thenConsumeWhile(x -> true)  // Predicate on elements
        .consumeRecordedWith(matches ->
            matches.forEach(v -> checkValue(v)))
        .verifyComplete();

UPD Simon Baslé 建议使用 thenConsumeWhile，它重新抛出 AssertionErrors。

StepVerifier.create(dataFlux)
        .thenConsumeWhile(v -> {
            assertThat(v).equalsTo(expected);
            return true;
        })
        .verifyComplete();

使用 StepVerifier 执行此任务的更规范的方法是：

StepVerifier.create(dataFlux)
        .thenConsumeWhile(v -> return expected.equals(v))
        .verifyComplete();

Answer 2

预期的方法是实际使用thenConsumeWhile运算符并提供谓词。如果序列中有任何元素不匹配，则会StepVerifier出错。

但它不是基于断言的，采用Predicatea 而不是Consumer。也就是说，您仍然可以使用断言库，任何断言库都AssertionError应该无法通过测试（您仍然必须返回虚假的谓词结果）。

（侧面警告：请记住，这不适用于无限序列）