use latest OperatorObserveOn from #2929

davidmoten · davidmoten · commit 7f85804c2372 · 2015-05-13T16:49:26.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);`