Merge pull request ReactiveX#3361 from artem-zinnatullin/blocking-to-future-better-error-handling

Safer error handling in BlockingOperatorToFuture

Author: abersnaze

src/main/java/rx/internal/operators/BlockingOperatorToFuture.java

@@ -118,8 +118,10 @@ public T get(long timeout, TimeUnit unit) throws InterruptedException, Execution
             }
 
             private T getValue() throws ExecutionException {
-                if (error.get() != null) {
-                    throw new ExecutionException("Observable onError", error.get());
+                final Throwable throwable = error.get();
+
+                if (throwable != null) {
+                    throw new ExecutionException("Observable onError", throwable);
                 } else if (cancelled) {
                     // Contract of Future.get() requires us to throw this:
                     throw new CancellationException("Subscription unsubscribed");