Merge pull request #1659 from davidmoten/scan-fix

OperatorScan should check for MAX_VALUE on request
ReactiveX · Sep 5, 2014 · 69fa2ff · 69fa2ff
2 parents c1b77dc + 56983e6
commit 69fa2ff
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rxjava-core/src/main/java/rx/internal/operators/OperatorScan.java b/rxjava-core/src/main/java/rx/internal/operators/OperatorScan.java
@@ -129,7 +129,7 @@ public void setProducer(final Producer producer) {
                     @Override
                     public void request(long n) {
                         if (once.compareAndSet(false, true)) {
-                            if (initialValue == NO_INITIAL_VALUE) {
+                            if (initialValue == NO_INITIAL_VALUE || n == Long.MAX_VALUE) {
                                 producer.request(n);
                             } else {
                                 producer.request(n - 1);