Merge pull request ReactiveX#2053 from akarnokd/ReplaySubjectBoundedF…

…ix1218 Fixed wrong bounded ReplaySubject use in test.
kiran-mk · Dec 18, 2014 · 9cae739 · 9cae739
2 parents 7c408f4 + 1a068dd
commit 9cae739
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();
+                    }
+                });
             }
         }
     }