Me gustaría verificar que cada emisión onNext coincida con el predicado dado.
expectNextMatches :
StepVerifier.create(...) .expectNextMatches { it.status != "SUCCESS" } .expectComplete() .verify()Sin embargo, solo coincide con una emisión, no con todas.
Hay un operador para eso:
StepVerifier.create(...) .thenConsumeWhile(it -> it.status != "SUCCESS") .expectComplete() .verify(); Si hay algún elemento en la secuencia que no coincide, StepVerifier generará un error.