We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 2ebacf0 + 00d33b7 commit 931e17eCopy full SHA for 931e17e
rxjava-core/src/main/java/rx/internal/operators/BlockingOperatorToIterator.java
@@ -89,18 +89,7 @@ public T next() {
89
}
90
91
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
+ return notifications.poll();
104
105
106
@Override
0 commit comments