Advertisement
Guest User

Untitled

a guest
Jul 26th, 2017
60
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.66 KB | None | 0 0
  1. getLayersObservable(id)
  2. .flatMap(new Function<List<Layer>, ObservableSource<Layer>>() {
  3. @Override
  4. public ObservableSource<Layer> apply(@NonNull List<Layer> layers) throws Exception {
  5. return Observable.fromIterable(layers);
  6. }
  7. })
  8. .flatMap(new Function<Layer, ObservableSource<ResponseBody>>() {
  9. @Override
  10. public ObservableSource<ResponseBody> apply(@NonNull Layer layer) throws Exception {
  11. String serverUrl = //buildurl
  12. return contentApiManager.downloadFile(serverUrl);
  13. }
  14. })
  15. .flatMap(new Function<ResponseBody, ObservableSource<File>>() {
  16. @Override
  17. public ObservableSource<File> apply(@NonNull ResponseBody body) throws Exception {
  18. return processResponseBody(body);
  19. }
  20. })
  21. .subscribeOn(Schedulers.io())
  22. .observeOn(AndroidSchedulers.mainThread())
  23. .toList()
  24. .subscribe(new Consumer<List<File>>() {
  25. @Override
  26. public void accept(@NonNull List<File> files) throws Exception {
  27. //todo process result.
  28. }
  29. }, new Consumer<Throwable>() {
  30. @Override
  31. public void accept(@NonNull Throwable throwable) throws Exception {
  32. Log.w("TAWWW", throwable);
  33. }
  34. });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement