StepVerifier
描述
到目前为止,你对每个练习的解答都是通过将 Publisher 你定义的答案传递给一个测试用例来检查的 StepVerifier。
该工件中的此类 reactor-test 能够订阅任何 Publisher (例如,Flux Akka Stream 或 A 流……),然后断言一组关于该序列的用户定义期望。
如果触发的任何事件与当前预期不符,则会 StepVerifier 产生一个 AssertionError。
StepVerifier 您可以从静态工厂获取一个实例 create。它提供了一个 DSL,用于设置数据部分的预期,并以单个终端预期(完成、错误、取消……)结束。
请注意,您必须始终调用该 verify() 方法或结合终端期望和验证的快捷方式之一,例如 .verifyErrorMessage(String)。否则,它将 StepVerifier 不会订阅您的序列,也不会断言任何内容。
StepVerifier.create(T<Publisher>).{expectations...}.verify()
有很多可能的预期,请参阅 参考文档 和 javadoc。