Skip to content

Commit 662ce3b

Browse files
committed
Merge pull request #3755 from akarnokd/FixtestErrorThrownIssue1685Again
1.x: fix attempt 2 for testErrorThrownIssue1685
2 parents a539151 + a3ca1fd commit 662ce3b

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/test/java/rx/ObservableTests.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1099,16 +1099,17 @@ public void uncaughtException(Thread t, Throwable e) {
10991099
}
11001100
}).get();
11011101

1102+
subject.subscribe();
1103+
11021104
Observable.error(new RuntimeException("oops"))
11031105
.materialize()
11041106
.delay(1, TimeUnit.SECONDS, s)
11051107
.dematerialize()
11061108
.subscribe(subject);
11071109

1108-
subject.subscribe();
11091110
subject.materialize().toBlocking().first();
11101111

1111-
for (int i = 0; i < 20 && err.get() == null; i++) {
1112+
for (int i = 0; i < 50 && err.get() == null; i++) {
11121113
Thread.sleep(100); // the uncaught exception comes after the terminal event reaches toBlocking
11131114
}
11141115

0 commit comments

Comments
 (0)