Merge pull request square#1119 from artem-zinnatullin/improve-error-h…

…andling-in-rx-call-adapter Improve error handling in RxJavaCallAdapterFactory
blzb · Sep 26, 2015 · 72c794f · 72c794f
2 parents 7e6bd27 + 187887b
commit 72c794f
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/retrofit-adapters/rxjava/src/main/java/retrofit/RxJavaCallAdapterFactory.java b/retrofit-adapters/rxjava/src/main/java/retrofit/RxJavaCallAdapterFactory.java
@@ -20,6 +20,7 @@
 import java.lang.reflect.Type;
 import rx.Observable;
 import rx.Subscriber;
+import rx.exceptions.Exceptions;
 import rx.functions.Action0;
 import rx.functions.Func1;
 import rx.subscriptions.Subscriptions;
@@ -112,6 +113,7 @@ private CallOnSubscribe(Call<T> originalCall) {
           subscriber.onNext(response);
         }
       } catch (Throwable t) {
+        Exceptions.throwIfFatal(t);
         if (!subscriber.isUnsubscribed()) {
           subscriber.onError(t);
         }