Fixed wrong subject use in test.

fxhpower · Dec 18, 2014 · 1a068dd · 1a068dd
1 parent 7c408f4
commit 1a068dd
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/test/java/rx/subjects/ReplaySubjectBoundedConcurrencyTest.java b/src/test/java/rx/subjects/ReplaySubjectBoundedConcurrencyTest.java
@@ -396,7 +396,12 @@ public void onNext(Object t) {
                 break;
             } else {
                 Assert.assertEquals(1, o.get());
-                rs.onCompleted();
+                worker.schedule(new Action0() {
+                    @Override
+                    public void call() {
+                        rs.onCompleted();
+                    }
+                });
             }
         }
     }