Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Observable.from(someList)
- .subscribeOn(Schedulers.io())
- .observeOn(Schedulers.io())
- .subscribe(listElement -> RxUtils.wrapRetrofitCall(doNetworkRequest(listElement.getId()))
- .observeOn(AndroidSchedulers.mainThread())
- .subscribe(new Subscriber<DataFromServer>() {
- @Override
- public void onCompleted() {
- //тут закончили
- }
- @Override
- public void onError(Throwable e) {
- e.printStackTrace();
- }
- @Override
- public void onNext(DataFromServer dataFromServer) {
- //тут получили очередные данные, чтото сделали с ними
- }
- }));
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement