add error handling in api observable

FabianTerhorst · Feb 2, 2016 · 9e9a339 · 9e9a339
1 parent 03b5ec9
commit 9e9a339
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/apiclient/src/main/java/io/fabianterhorst/apiclient/ApiObserver.java b/apiclient/src/main/java/io/fabianterhorst/apiclient/ApiObserver.java
@@ -40,8 +40,8 @@ public <Item extends RealmObject> Observable<List<Item>> getApiObservable(Observ
                         return objects;
                     });
             return Observable.create(subscriber -> {
-                realmObserver.subscribe(subscriber::onNext);
-                retrofitObserver.subscribe(subscriber::onNext);
+                realmObserver.subscribe(subscriber::onNext, subscriber::onError);
+                retrofitObserver.subscribe(subscriber::onNext, subscriber::onError);
             });
         } else
             return api.compose(applySchedulers());