我在用Spring做实验。我对java中的React流比较陌生。我正忙于研究如何在React流中测试和验证对象协作。我正在使用spring测试和reactor测试库进行tdd测试。
这是有缺陷的测试
@Test
void givenWeatherService_whenGetWeather_thenPublishWeatherAsync() throws Exception {
Mono<Sample> mono = service.updateWeatherFeed();
RecordedRequest request = server.takeRequest();
assertThat(request.getMethod()).isEqualTo("GET");
assertThat(request.getPath()).isEqualTo("/api/weather");
StepVerifier.create(mono)
.assertNext(sample -> {
verify(publisher, times(1)).publish(sample);
verify(sensorRepository, times(1)).insertSample(sample);
}).verifyComplete();
}下面是服务方法的实现
public Mono<Sample> updateWeatherFeed() {
// Uses WebClient to return the stream
Mono<Sample> mono = getWeather();
mono.doOnNext(sample -> {
sensorRepository.insertSample(sample);
samplePublisher.publish(sample);
}).subscribe();
return mono;
}stepverifier挂起以下日志：
10:21:01.827 [reactor-http-nio-2] DEBUG reactor.netty.resources.DefaultPooledConnectionProvider - [id: 0x81e9584a, L:/127.0.0.1:62510 - R:localhost/127.0.0.1:62479] Channel cleaned, now 1 active connections and 1 inactive connections正确的方法是什么来验证流是否已被使用以及参与的处理程序是否按顺序被调用？
1条答案
按热度按时间dwbf0jvd1#
你的问题可能是：
您将看到您正在订阅并因此使用流。如果您查看mono#subscribe的api，您可以看到它返回一个一次性的。这意味着它已经被消耗，并准备好被处置。
React流包括
producer和一个consumer. 这个consumer
subscribes到producer然后开始publishing. 发起呼叫的人是consumer因此应该是subscribe.在您的例子中，测试是发起调用的测试，因此测试是
consumer应该是那个subscribing.如果我们看看stepverifier#create，我们会发现它需要
Publisher而出版商是一个非消费者Mono或者Flux，不是Disposable.那么我们该如何解决这个问题，你需要移除
subscribe()```public Mono updateWeatherFeed() {
return getWeather().flatMap(sample -> {
sensorRepository.insertSample(sample);
samplePublisher.publish(sample);
return sample;
});
}
// Set up mocks and such
@Test
void doTest() throws Exception {
}