Skip to content

Commit eaff4d5

Browse files
Merge pull request ReactiveX#411 from petermd/fix-schedtests
update counter before triggering latch
2 parents 84dd240 + 7264f4d commit eaff4d5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

rxjava-core/src/test/java/rx/concurrency/TestSchedulers.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -361,8 +361,8 @@ public void testSchedulingWithDueTime() throws InterruptedException {
361361
@Override
362362
public Subscription call(Scheduler scheduler, String state) {
363363
System.out.println("doing work");
364-
latch.countDown();
365364
counter.incrementAndGet();
365+
latch.countDown();
366366
if (latch.getCount() == 0) {
367367
return Subscriptions.empty();
368368
} else {

0 commit comments

Comments
 (0)