diff --git a/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java b/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java index a0efb8968b..8b36948a9c 100644 --- a/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java +++ b/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java @@ -17,6 +17,7 @@ package org.springframework.http.server.reactive; import java.net.URI; +import java.time.Duration; import org.hamcrest.Matchers; import org.junit.Test; @@ -65,7 +66,7 @@ public class AsyncIntegrationTests extends AbstractHttpHandlerIntegrationTests { public Mono handle(ServerHttpRequest request, ServerHttpResponse response) { return response.setBody(Fluxion.just("h", "e", "l", "l", "o") .useTimer(Timer.global()) - .delay(1) + .delay(Duration.ofMillis(100)) .dispatchOn(asyncGroup) .collect(allocator::allocateBuffer, (buffer, str) -> buffer.write(str.getBytes()))); diff --git a/spring-web-reactive/src/test/java/org/springframework/web/reactive/method/annotation/RequestMappingIntegrationTests.java b/spring-web-reactive/src/test/java/org/springframework/web/reactive/method/annotation/RequestMappingIntegrationTests.java index 39b6057fe4..5e06c13dca 100644 --- a/spring-web-reactive/src/test/java/org/springframework/web/reactive/method/annotation/RequestMappingIntegrationTests.java +++ b/spring-web-reactive/src/test/java/org/springframework/web/reactive/method/annotation/RequestMappingIntegrationTests.java @@ -18,6 +18,7 @@ package org.springframework.web.reactive.method.annotation; import java.net.URI; import java.nio.ByteBuffer; +import java.time.Duration; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; @@ -491,7 +492,7 @@ public class RequestMappingIntegrationTests extends AbstractHttpHandlerIntegrati @RequestMapping("/stream-result") public Publisher stringStreamResponseBody() { - return Flux.interval(1).as(Fluxion::from).take(5); + return Flux.interval(Duration.ofSeconds(1)).as(Fluxion::from).take(5); } @RequestMapping("/raw-flux")