Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- List<Observable<Contributor>> observables = new ArrayList<>(2);
- observables.add(getSlowCachedDiskData());
- observables.add(getFreshNetworkData());
- Observable.concatEager(observables)
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread())
- .subscribe(contributor -> Log.d("TAG", "COMPLETED!"));
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement