Advertisement
Guest User

Untitled

a guest
Jun 10th, 2016
221
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 1.03 KB | None | 0 0
  1.  
  2. Observable.from(someList)
  3.                 .subscribeOn(Schedulers.io())
  4.                 .observeOn(Schedulers.io())
  5.                 .subscribe(listElement -> RxUtils.wrapRetrofitCall(doNetworkRequest(listElement.getId()))
  6.                         .observeOn(AndroidSchedulers.mainThread())
  7.                         .subscribe(new Subscriber<DataFromServer>() {
  8.                             @Override
  9.                             public void onCompleted() {
  10.                                 //тут закончили
  11.                             }
  12.  
  13.                             @Override
  14.                             public void onError(Throwable e) {
  15.                                 e.printStackTrace();
  16.                             }
  17.  
  18.                             @Override
  19.                             public void onNext(DataFromServer dataFromServer) {
  20.                                 //тут получили очередные данные, чтото сделали с ними
  21.                             }
  22.                         }));
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement