java - 用于间隔通量的模拟服务器？

Question

我尝试为一个服务编写一个测试函数，该服务消耗来自另一个服务的间隔 Flux，创建如Flux.interval(Duration.ofSeconds(1)).map( ... ).

如果看到Support of MockRestServiceServer for WebClient，这正是我所需要的。但是，目前推荐使用 OkHttp MockWebServer 代替。我现在的问题是：如何模拟提供间隔 Flux 的服务器响应？

MockResponsesetBody()函数接受 String 和 Buffer。可能缓冲区是要走的路。但是，我不知道如何将其转换Flux为InputStream可以读入缓冲区的说。

score 1 · Accepted Answer

为什么不直接使用 Mockito 来模拟该响应？基本上，使用 Mockito 来模拟 Service 调用。

例如，模拟一项将根据 id 为用户提供服务的服务

//mocked response
Mono<User> monoUser = Mono.just(new User());
Mockito.when(UserService.getUserBasedOnID(id)).thenReturn(monoUser);

1 回答 1