diff --git a/spring-web/src/test/java/org/springframework/http/server/reactive/AbstractHttpHandlerIntegrationTests.java b/spring-web/src/test/java/org/springframework/http/server/reactive/AbstractHttpHandlerIntegrationTests.java index 3ecd0b7a303..d3aedd70a6a 100644 --- a/spring-web/src/test/java/org/springframework/http/server/reactive/AbstractHttpHandlerIntegrationTests.java +++ b/spring-web/src/test/java/org/springframework/http/server/reactive/AbstractHttpHandlerIntegrationTests.java @@ -77,8 +77,8 @@ public abstract class AbstractHttpHandlerIntegrationTests { /** - * Return an interval stream of with n number of ticks and buffer the - * emissions to avoid back pressure failures (e.g. on slow CI server). + * Return an interval stream of N number of ticks and buffer the emissions + * to avoid back pressure failures (e.g. on slow CI server). * *

Use this method as follows: *

*/ public static Flux interval(Duration period, int count) { - return Flux.interval(period).take(count).onBackpressureBuffer(2); + return Flux.interval(period).take(count).onBackpressureBuffer(count); } }