@Override
public Observable<List<Gank>> getObservable() {
if (resId == -1) return null;
return getDataSupports().getGankData(type, mCurrentPage, PAGE_SIZE)
.map(new Func1<GankData, List<Gank>>() {
@Override
public List<Gank> call(GankData gankData) {
return gankData.getResults();
}
})
.flatMap(new Func1<List<Gank>, Observable<Gank>>() {
@Override
public Observable<Gank> call(List<Gank> ganks) {
return Observable.from(ganks);
}
})
.toSortedList(new Func2<Gank, Gank, Integer>() {
@Override
public Integer call(Gank gank, Gank gank2) {
return gank2.getPublishedAt().compareTo(gank.getPublishedAt());
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
}
GankPresenter.java 文件源码
java
阅读 22
收藏 0
点赞 0
评论 0
项目:yApp
作者:
评论列表
文章目录