blockFirst（）导致Reactor步进验证器试验失败

Question

下面是在数据库中检查重名的代码

public Mono<Void> validateDuplicateName(String name) throws RuntimeException {
    Flux<Customer> customerFlux = customerRepository.findByNameIgnoreCase(name);

    customerFlux.take(1).flatMap( customer -> {
        return Mono.error( new RuntimeException ("ABC99") );
    }).blockFirst();

    return Mono.empty();
}

下面是测试validateDuplicateName方法的测试脚本

when(customerRepositoryMocked.findByNameIgnoreCase(Mockito.anyString())).thenReturn(Flux.just(customerMocked));
StepVerifier.create(customerValidator.validateDuplicateName(Mockito.anyString()))
        .expectErrorMatches( exception -> exception instanceof RuntimeException )
        .verify();

但是测试失败，出现以下错误

java.lang.RuntimeException: ABC99
..
..
Suppressed: java.lang.Exception: #block terminated with an error
        at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:93)
        at reactor.core.publisher.Flux.blockFirst(Flux.java:2013)
        ... 34 more

我能找人帮忙吗？

Answer 1

您的stepverifier实际上只能测试方法系统返回的mono.empty()。同时，您可以使用blockfirst，这将引发发布服务器发出的任何异常，从而缩短整个断言。

记住stepverifier允许您断言预期序列将异步发出的内容（包括错误，以onerror信号的形式）。如果因为创建序列的方法(validateduplicateName)抛出而无法创建序列，那么stepverifier就无能为力了。

但真正的问题是，您究竟为什么要阻塞一个具有mono返回类型并具有非常好的mono源代码的方法？返回的mono必须从该CustomerFlux派生。