Fix toIterator Exception Handling

Author: benjchristensen

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

@@ -55,7 +55,7 @@ public void onCompleted() {
 
             @Override
             public void onError(Throwable e) {
-                // ignore
+                notifications.offer(Notification.<T>createOnError(e));
             }
 
             @Override

rxjava-core/src/test/java/rx/internal/operators/BlockingOperatorToIteratorTest.java

@@ -67,4 +67,18 @@ public void call(Subscriber<? super String> observer) {
         assertEquals(true, it.hasNext());
         it.next();
     }
+
+    @Test(expected = TestException.class)
+    public void testExceptionThrownFromOnSubscribe() {
+        Iterable<String> strings = Observable.create(new Observable.OnSubscribe<String>() {
+            @Override
+            public void call(Subscriber<? super String> subscriber) {
+                throw new TestException("intentional");
+            }
+        }).toBlocking().toIterable();
+        for (String string : strings) {
+            // never reaches here
+            System.out.println(string);
+        }
+    }
 }