unit-testing - Project Reactor block() 与 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();
}

以我的愚见，我会说第二种方法看起来更 react 。此外，官方文档对此非常明确:

A StepVerifier provides a declarative way of creating a verifiable script for an async Publisher sequence, by expressing expectations about the events that will happen upon subscription.

不过，我真的很好奇，应该鼓励使用什么方式作为在 Reactor 中进行测试的主要途径。 .block() 方法应该完全放弃还是在某些情况下有用？如果是，这些情况是什么？

谢谢!

Answer 1

你应该使用 StepVerifier .它允许更多选项:

• 验证您预期通量中有 n 个元素
• 验证通量/单声道是否完成
• 验证是否会出现错误
• 验证序列是否为 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(); 
}

• 创建 initial context
• Using virtual time to manipulate time .因此，当您有类似 Mono.delay(Duration.ofDays(1)) 的内容时，您无需等待 1 天即可完成测试。
• 预计在给定的持续时间内不会发出任何事件...