如何对具有 Mono 返回类型的方法进行 junit 测试

Question

junit mono 并获得身体响应的正确方法是什么？ 我希望“仅单项”出现在 MockHttpServletResponse 的正文响应中。但相反，我看到它以异步方式返回。

样本方法：

public Mono<String> getData(final String data) {
    return this.webClient.get().uri("/dataValue/" + data)
        .retrieve()
        .bodyToMono(String.class);
}

Junit 示例：

@WebMvcTest(DataController.class)
public class DataMockTest {

  @Autowired
  private MockMvc mockMvc;

  @MockBean
  private Service service;

@Test
public void getDataTest() throws Exception {

Mono<String> strMono = Mono.just("Single Item Only");

when(service.getData("DATA")).thenReturn(strMono);

this.mockMvc.perform(get("/some/rest/toget/data")
    .contentType(MediaType.APPLICATION_JSON)
    .accept(MediaType.APPLICATION_JSON))
    .andDo(print())
    .andExpect(status()
        .isOk());
}

测试响应：

MockHttpServletRequest:
      HTTP Method = GET
      Request URI = /some/rest/toget/data
       Parameters = {}
          Headers = [Content-Type:"application/json;charset=UTF-8", Accept:"application/json"]
             Body = null
    Session Attrs = {}

Async:
    Async started = true
     Async result = Single Item Only

Resolved Exception:
             Type = null

ModelAndView:
        View name = null
             View = null
            Model = null

FlashMap:
       Attributes = null

MockHttpServletResponse:
           Status = 200
    Error message = null
          Headers = []
     Content type = null
             Body = 
    Forwarded URL = null
   Redirected URL = null
          Cookies = []

使用 StepVerifier 更新了 Junit：

@WebMvcTest(DataController.class)
public class DataMockTest {

  @Autowired
  private MockMvc mockMvc;

  @MockBean
  private Service service;

@Test
public void getDataTest() throws Exception {

Mono<String> strMono = Mono.just("Single Item Only");

when(service.getData("DATA")).thenReturn(strMono);

//Added this which verifies the mono method. How to mock it so the API would return the mono value?
StepVerifier.create(service.getDATA("DATA"))
    .assertNext(data -> {
      assertNotNull(data);
      assertEquals("Single Item Only", data);
    }).verifyComplete();


this.mockMvc.perform(get("/some/rest/toget/data")
    .contentType(MediaType.APPLICATION_JSON)
    .accept(MediaType.APPLICATION_JSON))
    .andDo(print())
    .andExpect(status()
        .isOk());
}

Answer 1

在我看来，您期待的是 StepVerifier。有了它，您可以断言 Mono 和 Flux 数据类型的内容。请参考https://www.baeldung.com/reactive-streams-step-verifier-test-publisher。