Merge pull request #8 from Scit/master

Fix Api-subscriber's onCompleted call before realm data is loaded
FabianTerhorst · Aug 5, 2016 · be60099 · be60099
2 parents 94298d9 + 9837954
commit be60099
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
@@ -44,8 +44,8 @@ public <Item extends RealmObject> Observable<List<Item>> getApiObservable(Observ
                     .compose(applySchedulers())
                     .compose(getLifecycle());
             return Observable.<List<Item>>create(subscriber -> {
-                realmObserver.subscribe(subscriber::onNext, subscriber::onError);
-                retrofitObserver.subscribe(this::setItems, subscriber::onError, subscriber::onCompleted);
+                realmObserver.take(2).subscribe(subscriber::onNext, subscriber::onError, subscriber::onCompleted);
+                retrofitObserver.subscribe(this::setItems, subscriber::onError);
             }).compose(getLifecycle());
         } else
             return api;