Reactor 测试 Stepverifier - 检查每个下一个事件是否匹配谓词

Question

我想验证每个 onNext 发射都匹配给定的谓词。

我试过了expectNextMatches:

StepVerifier.create(...)
    .expectNextMatches { it.status != "SUCCESS" }
    .expectComplete()
    .verify()

但是，它只匹配一个发射，而不是每一个发射。

Answer 1

有一个运算符：

StepVerifier.create(...)
    .thenConsumeWhile(it -> it.status != "SUCCESS")
    .expectComplete()
    .verify();

如果序列中有任何元素不匹配，StepVerifier 将出错。