Fix FluxLatest not updating the local requested amount after emission

reactor · Mar 17, 2016 · e5a23a2 · e5a23a2
1 parent 6897abd
commit e5a23a2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/reactor/core/publisher/FluxLatest.java b/src/main/java/reactor/core/publisher/FluxLatest.java
@@ -177,7 +177,7 @@ void drain() {
 					a.onNext(v);
 
 					if (r != Long.MAX_VALUE) {
-						REQUESTED.decrementAndGet(this);
+						r = REQUESTED.decrementAndGet(this);
 					}
 				}