We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 005f1bb + 76c80a8 commit de259a3Copy full SHA for de259a3
src/main/java/rx/observers/TestSubscriber.java
@@ -226,9 +226,7 @@ public void awaitTerminalEvent() {
226
*/
227
public void awaitTerminalEvent(long timeout, TimeUnit unit) {
228
try {
229
- if (!latch.await(timeout, unit)) {
230
- throw new RuntimeException(new TimeoutException());
231
- }
+ latch.await(timeout, unit);
232
} catch (InterruptedException e) {
233
throw new RuntimeException("Interrupted", e);
234
}
0 commit comments