Remove Temporary Timeout in take

benjchristensen · benjchristensen · commit e128ffe3c047 · 2014-08-12T12:26:29.000-07:00
Fix it properly this time :-)
diff --git a/rxjava-core/src/main/java/rx/internal/operators/BlockingOperatorToIterator.java b/rxjava-core/src/main/java/rx/internal/operators/BlockingOperatorToIterator.java
@@ -89,7 +89,11 @@ public T next() {
             }
 
             private Notification<? extends T> take() {
-                return notifications.poll();
+                try {
+                    return notifications.take();
+                } catch (InterruptedException e) {
+                    throw Exceptions.propagate(e);
+                }
             }
 
             @Override

Original file line number	Diff line number	Diff line change
`@@ -89,7 +89,11 @@ public T next() {`
`89`	`89`	`}`
`90`	`90`
`91`	`91`	`private Notification<? extends T> take() {`
`92`		`- return notifications.poll();`
	`92`	`+ try {`
	`93`	`+ return notifications.take();`
	`94`	`+ } catch (InterruptedException e) {`
	`95`	`+ throw Exceptions.propagate(e);`
	`96`	`+ }`
`93`	`97`	`}`
`94`	`98`
`95`	`99`	`@Override`