BlockingOperatorToIterator hanging when exception is thrown from OnSubscribe.call(..)

[atychyna]

See code snippet bellow. Basically in BlockingOperatorToIterator.toIterator() method "lifted" subscriber ignores exception in onError(..) method what makes iterator's hasNext(..) method to wait forever for a notification that never arrives.

Iterable<String> strings = Observable.create(new Observable.OnSubscribe<String>() {
    @Override
    public void call(Subscriber<? super String> subscriber) {
        throw new RuntimeException("intentional");
    }
}).toBlocking().toIterable();
for (String string : strings) {
    // never reaches here
}

[benjchristensen]

Thanks for this report. Fix coming ...