Skip to content

Commit 9cae739

Browse files
Merge pull request #2053 from akarnokd/ReplaySubjectBoundedFix1218
Fixed wrong bounded ReplaySubject use in test.
2 parents 7c408f4 + 1a068dd commit 9cae739

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

src/test/java/rx/subjects/ReplaySubjectBoundedConcurrencyTest.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -396,7 +396,12 @@ public void onNext(Object t) {
396396
break;
397397
} else {
398398
Assert.assertEquals(1, o.get());
399-
rs.onCompleted();
399+
worker.schedule(new Action0() {
400+
@Override
401+
public void call() {
402+
rs.onCompleted();
403+
}
404+
});
400405
}
401406
}
402407
}

0 commit comments

Comments
 (0)