don't reduce requested by produced if requested is Long.MAX_VALUE

davidmoten · davidmoten · commit c9d932420cb6 · 2015-05-13T16:28:14.000+10:00
diff --git a/src/main/java/rx/internal/operators/OperatorObserveOn.java b/src/main/java/rx/internal/operators/OperatorObserveOn.java
@@ -214,7 +214,7 @@ void pollQueue() {
                         break;
                     }
                 }
-                if (produced > 0) {
+                if (produced > 0 && requested != Long.MAX_VALUE) {
                     REQUESTED.addAndGet(this, -produced);
                 }
             } while (COUNTER_UPDATER.decrementAndGet(this) > 0);

Original file line number	Diff line number	Diff line change
`@@ -214,7 +214,7 @@ void pollQueue() {`
`214`	`214`	`break;`
`215`	`215`	`}`
`216`	`216`	`}`
`217`		`- if (produced > 0) {`
	`217`	`+ if (produced > 0 && requested != Long.MAX_VALUE) {`
`218`	`218`	`REQUESTED.addAndGet(this, -produced);`
`219`	`219`	`}`
`220`	`220`	`} while (COUNTER_UPDATER.decrementAndGet(this) > 0);`