diff --git a/rxjava-core/src/test/java/rx/concurrency/TestSchedulers.java b/rxjava-core/src/test/java/rx/concurrency/TestSchedulers.java index 4241ee3f84..7d2851abf9 100644 --- a/rxjava-core/src/test/java/rx/concurrency/TestSchedulers.java +++ b/rxjava-core/src/test/java/rx/concurrency/TestSchedulers.java @@ -361,8 +361,8 @@ public void testSchedulingWithDueTime() throws InterruptedException { @Override public Subscription call(Scheduler scheduler, String state) { System.out.println("doing work"); - latch.countDown(); counter.incrementAndGet(); + latch.countDown(); if (latch.getCount() == 0) { return Subscriptions.empty(); } else {