From 21203921f08fb98fe1bfdadec3efe63bb9fc2894 Mon Sep 17 00:00:00 2001
From: Stephane Maldini <smaldini@pivotal.io>
Date: Fri, 22 Sep 2017 13:56:39 -0700
Subject: [PATCH] sync with reactor-core snapshot

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

diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerReadPublisher.java b/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerReadPublisher.java
index 487a19ff39..513eb7810d 100644
--- a/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerReadPublisher.java
+++ b/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerReadPublisher.java
@@ -223,7 +223,7 @@ public abstract class AbstractListenerReadPublisher<T> implements Publisher<T> {
 			@Override
 			<T> void request(AbstractListenerReadPublisher<T> publisher, long n) {
 				if (Operators.validate(n)) {
-					Operators.addAndGet(DEMAND_FIELD_UPDATER, publisher, n);
+					Operators.addCap(DEMAND_FIELD_UPDATER, publisher, n);
 					if (publisher.changeState(this, DEMAND)) {
 						publisher.checkOnDataAvailable();
 					}
@@ -241,7 +241,7 @@ public abstract class AbstractListenerReadPublisher<T> implements Publisher<T> {
 			@Override
 			<T> void request(AbstractListenerReadPublisher<T> publisher, long n) {
 				if (Operators.validate(n)) {
-					Operators.addAndGet(DEMAND_FIELD_UPDATER, publisher, n);
+					Operators.addCap(DEMAND_FIELD_UPDATER, publisher, n);
 				}
 			}
 
@@ -269,7 +269,7 @@ public abstract class AbstractListenerReadPublisher<T> implements Publisher<T> {
 			@Override
 			<T> void request(AbstractListenerReadPublisher<T> publisher, long n) {
 				if (Operators.validate(n)) {
-					Operators.addAndGet(DEMAND_FIELD_UPDATER, publisher, n);
+					Operators.addCap(DEMAND_FIELD_UPDATER, publisher, n);
 				}
 			}
 		},