From bf40e09d9d1a8c0cdad7ab113af069391f2d0c7c Mon Sep 17 00:00:00 2001
From: Samuel Tardieu <sam@rfc1149.net>
Date: Sun, 15 Jun 2014 01:25:41 +0200
Subject: [PATCH] Fix a race condition if queued actions have been handled
 already

---
 .../src/main/java/rx/internal/operators/OperatorObserveOn.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/rxjava-core/src/main/java/rx/internal/operators/OperatorObserveOn.java b/rxjava-core/src/main/java/rx/internal/operators/OperatorObserveOn.java
index f7e348269a..42bad82670 100644
--- a/rxjava-core/src/main/java/rx/internal/operators/OperatorObserveOn.java
+++ b/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);