} catch (Throwable ex) {
            Exceptions.throwIfFatal(ex);
            // if an unhandled error occurs executing the onSubscribe we will propagate it
            try {
                te.onError(RxJavaHooks.onSingleError(ex));