From 1b98d09855477df1d05a498e2749546fe0c1908d Mon Sep 17 00:00:00 2001
From: Rossen Stoyanchev <rstoyanchev@pivotal.io>
Date: Tue, 6 Feb 2018 15:43:05 -0500
Subject: [PATCH] Fix copy+paste error

---
 .../reactive/AbstractHttpHandlerIntegrationTests.java       | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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).
 	 *
 	 * <p>Use this method as follows:
 	 * <ul>
@@ -89,7 +89,7 @@ public abstract class AbstractHttpHandlerIntegrationTests {
 	 * </ul>
 	 */
 	public static Flux<Long> interval(Duration period, int count) {
-		return Flux.interval(period).take(count).onBackpressureBuffer(2);
+		return Flux.interval(period).take(count).onBackpressureBuffer(count);
 	}
 
 }