Merge pull request #236 from mairbek/sleepingfix

Fixed Sleeping Action
ReactiveX · Apr 18, 2013 · 34e097b · 34e097b
2 parents b66557c + 00a362e
commit 34e097b
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/rxjava-core/src/main/java/rx/concurrency/SleepingAction.java b/rxjava-core/src/main/java/rx/concurrency/SleepingAction.java
@@ -34,13 +34,17 @@ public SleepingAction(Func2<Scheduler, T, Subscription> underlying, Scheduler sc
 
     @Override
     public Subscription call(Scheduler s, T state) {
-        if (execTime < scheduler.now()) {
+        if (execTime > scheduler.now()) {
+            long delay = execTime - scheduler.now();
+            if (delay> 0) {
             try {
-                Thread.sleep(scheduler.now() - execTime);
-            } catch (InterruptedException e) {
+                    Thread.sleep(delay);
+                }
+             catch (InterruptedException e) {
                 Thread.currentThread().interrupt();
                 throw new RuntimeException(e);
             }
+            }
         }
 
         return underlying.call(s, state);