Added capacity increase on poll.

akarnokd · akarnokd · commit 34bf40aa7536 · 2015-01-26T13:33:45.000+01:00
diff --git a/src/main/java/rx/internal/operators/OperatorOnBackpressureBuffer.java b/src/main/java/rx/internal/operators/OperatorOnBackpressureBuffer.java
@@ -125,7 +125,11 @@ public Object peek() {
         }
         @Override
         public Object poll() {
-            return queue.poll();
+            Object value = queue.poll();
+            if (capacity != null) {
+                capacity.incrementAndGet();
+            }
+            return value;
         }
         
         private boolean assertCapacity() {

Original file line number	Diff line number	Diff line change
`@@ -125,7 +125,11 @@ public Object peek() {`
`125`	`125`	`}`
`126`	`126`	`@Override`
`127`	`127`	`public Object poll() {`
`128`		`- return queue.poll();`
	`128`	`+ Object value = queue.poll();`
	`129`	`+ if (capacity != null) {`
	`130`	`+ capacity.incrementAndGet();`
	`131`	`+ }`
	`132`	`+ return value;`
`129`	`133`	`}`
`130`	`134`
`131`	`135`	`private boolean assertCapacity() {`