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.
1 parent 7fdde98 commit cb6333eCopy full SHA for cb6333e
rxjava-core/src/main/java/rx/internal/operators/BlockingOperatorToIterator.java
@@ -90,6 +90,7 @@ public T next() {
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");
0 commit comments