Skip to content

Commit f763dad

Browse files
Merge pull request #986 from benjchristensen/issue-985
Fix SynchronizedObserver.runConcurrencyTest
2 parents 7e7aebf + 792fffe commit f763dad

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

rxjava-core/src/test/java/rx/observers/SynchronizedObserverTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -361,14 +361,14 @@ public void runConcurrencyTest() {
361361

362362
// 12000 + 5000 + 75000 + 13500 + 22000 + 15000 + 7500 + 23500 = 173500
363363

364-
Future<?> f10 = tp.submit(new CompletionThread(w, TestConcurrencyObserverEvent.onCompleted, f1, f2, f3, f4));
364+
Future<?> f10 = tp.submit(new CompletionThread(w, TestConcurrencyObserverEvent.onCompleted, f1, f2, f3, f4, f5, f6, f7, f8));
365365
try {
366366
Thread.sleep(1);
367367
} catch (InterruptedException e) {
368368
// ignore
369369
}
370370

371-
waitOnThreads(f1, f2, f3, f4, f5, f6, f7, f8, f10);
371+
waitOnThreads(f10);
372372
@SuppressWarnings("unused")
373373
int numNextEvents = tw.assertEvents(null); // no check of type since we don't want to test barging results here, just interleaving behavior
374374
assertEquals(173500, numNextEvents);

0 commit comments

Comments
 (0)