Merge pull request #1361 from samueltardieu/queued-actions

Fix a race condition if queued actions have been handled already

Author: benjchristensen

rxjava-core/src/main/java/rx/internal/operators/OperatorObserveOn.java

@@ -138,7 +138,7 @@ private void pollQueue() {
                     }
                     on.accept(observer, v);
                 }
-                if (COUNTER_UPDATER.addAndGet(this, -vs.size) == 0) {
+                if (COUNTER_UPDATER.addAndGet(this, -vs.size) <= 0) {
                     break;
                 }
             } while (true);