Skip to content

Commit 1b98d09

Browse files
committed
Fix copy+paste error
1 parent 9551b3a commit 1b98d09

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

spring-web/src/test/java/org/springframework/http/server/reactive/AbstractHttpHandlerIntegrationTests.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -77,8 +77,8 @@ public void tearDown() throws Exception {
7777

7878

7979
/**
80-
* Return an interval stream of with n number of ticks and buffer the
81-
* emissions to avoid back pressure failures (e.g. on slow CI server).
80+
* Return an interval stream of N number of ticks and buffer the emissions
81+
* to avoid back pressure failures (e.g. on slow CI server).
8282
*
8383
* <p>Use this method as follows:
8484
* <ul>
@@ -89,7 +89,7 @@ public void tearDown() throws Exception {
8989
* </ul>
9090
*/
9191
public static Flux<Long> interval(Duration period, int count) {
92-
return Flux.interval(period).take(count).onBackpressureBuffer(2);
92+
return Flux.interval(period).take(count).onBackpressureBuffer(count);
9393
}
9494

9595
}

0 commit comments

Comments
 (0)