使用 Mono Stepverifier 的反应式测试用例答案

【问题标题】：Reactive Test case with Mono Stepverifier使用 Mono Stepverifier 的反应式测试用例
【发布时间】：2021-12-01 08:19:03
【问题描述】：

我是 Spring webflux 中反应式编程的新手。我有以下情况。

在尝试为 Mono<List<MyClass>> 编写测试用例时，我遇到了一个错误。

List<MyResponse> response= List.of(MyResponse.builder()
    .separator("value").build());
MyRequest request= StubGenerator.getRequest();

mockServer.enqueue(new MockResponse()
        .setBody("{\"separator\":\"value\"}")
        .addHeader("Content-Type", "application/json"));

Mono<List<MyResponse>> responseMono = MyService.getResponse(request, "token");

StepVerifier.create(responseMono)
    .expectNext(response)
    .verifyComplete();

我收到 JSON 反序列化错误

java.lang.AssertionError: expectation "expectNext([MyResponse(errorReason=null, separator=value)])" failed 
(expected value: [MyResponse(errorReasonInvSeparator=null, invoiceSeparator=value)]; actual value: [MyResponse(errorReasonInvSeparator=JSON decoding error: Cannot deserialize value of type `java.util.ArrayList<net.model.MyResponse>` from Object value (token `JsonToken.START_OBJECT`); 
nested exception is com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `java.util.ArrayList<net.model.MyResponse>` from Object value (token `JsonToken.START_OBJECT`)

【问题讨论】：

标签： spring-boot unit-testing reactive-programming spring-webflux webflux

【解决方案1】：

您将主体设置为单个对象，但您希望它是一个列表。您需要按如下方式更改正文中的 JSON（注意[ (...) ]）：

mockServer.enqueue(new MockResponse()
        .setBody("[ {\"separator\":\"value\"} ]")
        .addHeader("Content-Type", "application/json"));

【讨论】：

为我工作，非常感谢:)