From d736245f28e71b0a9d462c8197b61f417acace5b Mon Sep 17 00:00:00 2001 From: Arjen Poutsma Date: Tue, 12 Jul 2016 13:25:18 +0200 Subject: [PATCH] Changed from interval() to intervalMillis() --- .../http/server/reactive/FlushingIntegrationTests.java | 2 +- .../method/annotation/RequestMappingIntegrationTests.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/FlushingIntegrationTests.java b/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/FlushingIntegrationTests.java index 831e5a55ad..16b608e60e 100644 --- a/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/FlushingIntegrationTests.java +++ b/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/FlushingIntegrationTests.java @@ -72,7 +72,7 @@ public class FlushingIntegrationTests extends AbstractHttpHandlerIntegrationTest @Override public Mono handle(ServerHttpRequest request, ServerHttpResponse response) { Flux responseBody = Flux - .interval(50) + .intervalMillis(50) .map(l -> { byte[] data = ("data" + l).getBytes(); DataBuffer buffer = response.bufferFactory().allocateBuffer(data.length); diff --git a/spring-web-reactive/src/test/java/org/springframework/web/reactive/result/method/annotation/RequestMappingIntegrationTests.java b/spring-web-reactive/src/test/java/org/springframework/web/reactive/result/method/annotation/RequestMappingIntegrationTests.java index 3b5a332319..b5fc3627b2 100644 --- a/spring-web-reactive/src/test/java/org/springframework/web/reactive/result/method/annotation/RequestMappingIntegrationTests.java +++ b/spring-web-reactive/src/test/java/org/springframework/web/reactive/result/method/annotation/RequestMappingIntegrationTests.java @@ -82,7 +82,7 @@ public class RequestMappingIntegrationTests extends AbstractRequestMappingIntegr @GetMapping("/stream-result") public Publisher stringStreamResponseBody() { - return Flux.interval(100).take(5); + return Flux.intervalMillis(100).take(5); } }