正确的测试模式在项目Reactor块（）vs StepVerifier

Question

最近，我注意到我的团队在如何在Reactor中编写测试方面遵循了两种方法。第一个方法是借助.block()方法。它看起来是这样的：

@Test
void set_entity_version() {
    Entity entity = entityRepo.findById(ID)
                              .block();
    assertNotNull(entity);
    assertFalse(entity.isV2());

    entityService.setV2(ID)
                 .block();

    Entity entity = entityRepo.findById(ID)
                              .block();

    assertNotNull(entity);
    assertTrue(entity.isV2());
}

第二部分是关于stepverifier的使用。它看起来是这样的：

@Test
void set_entity_version() {

    StepVerifier.create(entityRepo.findById(ID))
                .assertNext(entity -> {
                    assertNotNull(entity);
                    assertFalse(entity.isV2());
                })
                .verifyComplete();
            
    StepVerifier.create(entityService.setV2(ID)
                                     .then(entityRepo.findById(ID)))
                .assertNext(entity -> {
                    assertNotNull(entity);
                    assertTrue(entity.isV2());
                })
                .verifyComplete();
}

以我的拙见，第二种方法看起来更被动。此外，官方文件对此非常清楚：

不过，我还是很好奇，应该鼓励什么样的方式作为Reactor测试的主要途径。是否应该完全放弃.block()方法？若有，是甚么情况？

谢了！

Answer 1

你应该使用步进验证器。它允许更多的选择：

• 验证流量中是否有n个元素
• 验证流量/mono是否完成
• 验证是否出现错误
• 验证序列是否需要n个元素后接错误（无法用.block（）进行测试）

来自官方文档：

public <T> Flux<T> appendBoomError(Flux<T> source) {
  return source.concatWith(Mono.error(new IllegalArgumentException("boom")));
}

@Test
public void testAppendBoomError() {
  Flux<String> source = Flux.just("thing1", "thing2"); 

  StepVerifier.create( 
    appendBoomError(source)) 
    .expectNext("thing1") 
    .expectNext("thing2")
    .expectErrorMessage("boom") 
    .verify(); 
}

null