diff --git a/spring-webflux/src/test/java/org/springframework/web/reactive/FlushingIntegrationTests.java b/spring-webflux/src/test/java/org/springframework/web/reactive/FlushingIntegrationTests.java index 994a3bdb8c..0a429c67af 100644 --- a/spring-webflux/src/test/java/org/springframework/web/reactive/FlushingIntegrationTests.java +++ b/spring-webflux/src/test/java/org/springframework/web/reactive/FlushingIntegrationTests.java @@ -127,7 +127,7 @@ class FlushingIntegrationTests extends AbstractHttpHandlerIntegrationTests { String path = request.getURI().getPath(); return switch (path) { case "/write-and-flush" -> response.writeAndFlushWith( - testInterval(Duration.ofMillis(50), 2) + testInterval(Duration.ofMillis(1), 2) .map(longValue -> wrap("data" + longValue + "\n", response)) .map(Flux::just) .mergeWith(Flux.never())); diff --git a/spring-webflux/src/test/java/org/springframework/web/reactive/function/server/SseHandlerFunctionIntegrationTests.java b/spring-webflux/src/test/java/org/springframework/web/reactive/function/server/SseHandlerFunctionIntegrationTests.java index a5e65f4612..76333bc929 100644 --- a/spring-webflux/src/test/java/org/springframework/web/reactive/function/server/SseHandlerFunctionIntegrationTests.java +++ b/spring-webflux/src/test/java/org/springframework/web/reactive/function/server/SseHandlerFunctionIntegrationTests.java @@ -125,7 +125,7 @@ class SseHandlerFunctionIntegrationTests extends AbstractRouterFunctionIntegrati private static class SseHandler { - private static final Flux INTERVAL = testInterval(Duration.ofMillis(100), 2); + private static final Flux INTERVAL = testInterval(Duration.ofMillis(1), 2); Mono string(ServerRequest request) { return ServerResponse.ok() diff --git a/spring-webflux/src/test/java/org/springframework/web/reactive/result/method/annotation/JacksonStreamingIntegrationTests.java b/spring-webflux/src/test/java/org/springframework/web/reactive/result/method/annotation/JacksonStreamingIntegrationTests.java index 7cbec1f258..047d334f3f 100644 --- a/spring-webflux/src/test/java/org/springframework/web/reactive/result/method/annotation/JacksonStreamingIntegrationTests.java +++ b/spring-webflux/src/test/java/org/springframework/web/reactive/result/method/annotation/JacksonStreamingIntegrationTests.java @@ -109,7 +109,7 @@ class JacksonStreamingIntegrationTests extends AbstractHttpHandlerIntegrationTes @GetMapping(value = "/stream", produces = { APPLICATION_NDJSON_VALUE, "application/stream+x-jackson-smile" }) Flux person() { - return testInterval(Duration.ofMillis(100), 50).map(l -> new Person("foo " + l)); + return testInterval(Duration.ofMillis(1), 50).map(l -> new Person("foo " + l)); } } diff --git a/spring-webflux/src/test/java/org/springframework/web/reactive/result/method/annotation/ProtobufIntegrationTests.java b/spring-webflux/src/test/java/org/springframework/web/reactive/result/method/annotation/ProtobufIntegrationTests.java index ef8ed31a95..6fd4f3767a 100644 --- a/spring-webflux/src/test/java/org/springframework/web/reactive/result/method/annotation/ProtobufIntegrationTests.java +++ b/spring-webflux/src/test/java/org/springframework/web/reactive/result/method/annotation/ProtobufIntegrationTests.java @@ -168,7 +168,7 @@ class ProtobufIntegrationTests extends AbstractRequestMappingIntegrationTests { @GetMapping(value = "/message-stream", produces = "application/x-protobuf;delimited=true") Flux messageStream() { - return testInterval(Duration.ofMillis(50), 5).map(l -> + return testInterval(Duration.ofMillis(1), 5).map(l -> Msg.newBuilder().setFoo("Foo").setBlah(SecondMsg.newBuilder().setBlah(l.intValue()).build()).build()); } diff --git a/spring-webflux/src/test/java/org/springframework/web/reactive/result/method/annotation/RequestMappingIntegrationTests.java b/spring-webflux/src/test/java/org/springframework/web/reactive/result/method/annotation/RequestMappingIntegrationTests.java index 34d8a2cd6d..b33e39a399 100644 --- a/spring-webflux/src/test/java/org/springframework/web/reactive/result/method/annotation/RequestMappingIntegrationTests.java +++ b/spring-webflux/src/test/java/org/springframework/web/reactive/result/method/annotation/RequestMappingIntegrationTests.java @@ -177,7 +177,7 @@ class RequestMappingIntegrationTests extends AbstractRequestMappingIntegrationTe @GetMapping("/stream") public Publisher stream() { - return testInterval(Duration.ofMillis(50), 5); + return testInterval(Duration.ofMillis(1), 5); } } diff --git a/spring-webflux/src/test/java/org/springframework/web/reactive/result/method/annotation/SseIntegrationTests.java b/spring-webflux/src/test/java/org/springframework/web/reactive/result/method/annotation/SseIntegrationTests.java index 205ff217a8..92a82ba71d 100644 --- a/spring-webflux/src/test/java/org/springframework/web/reactive/result/method/annotation/SseIntegrationTests.java +++ b/spring-webflux/src/test/java/org/springframework/web/reactive/result/method/annotation/SseIntegrationTests.java @@ -202,7 +202,7 @@ class SseIntegrationTests extends AbstractHttpHandlerIntegrationTests { @RequestMapping("/sse") static class SseController { - private static final Flux INTERVAL = testInterval(Duration.ofMillis(100), 50); + private static final Flux INTERVAL = testInterval(Duration.ofMillis(1), 50); private final Sinks.Empty cancelSink = Sinks.empty();