Skip to content

Commit 00d33b7

Browse files
Remove Timeout in Blocking Iterator
This was a temporary timeout to track down bugs.
1 parent 62ce4ac commit 00d33b7

File tree

1 file changed

+1
-12
lines changed

1 file changed

+1
-12
lines changed

rxjava-core/src/main/java/rx/internal/operators/BlockingOperatorToIterator.java

Lines changed: 1 addition & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -89,18 +89,7 @@ public T next() {
8989
}
9090

9191
private Notification<? extends T> take() {
92-
try {
93-
// TODO remove this timeout and logging before final release of 0.20
94-
Notification<? extends T> n = notifications.poll(10000, TimeUnit.MILLISECONDS);
95-
if(n == null) {
96-
System.err.println("Timed out waiting for value. File a bug at github.com/Netflix/RxJava");
97-
throw new RuntimeException("Timed out waiting for value. File a bug at github.com/Netflix/RxJava");
98-
} else {
99-
return n;
100-
}
101-
} catch (InterruptedException e) {
102-
throw Exceptions.propagate(e);
103-
}
92+
return notifications.poll();
10493
}
10594

10695
@Override

0 commit comments

Comments
 (0)