Network.java 文件源码

public static void getNews(SingleObserver<List<News.ContentBean>> observer)
{
    service.getNews()
           .subscribeOn(Schedulers.newThread())
           .flatMap(new Function<News, Observable<News.ContentBean>>()
           {
               @Override
               public Observable<News.ContentBean> apply(News news) throws Exception
               {
                   L.e();
                   return Observable.fromIterable(news.getT1348647853363());
               }
           })
           .toList()
           .observeOn(AndroidSchedulers.mainThread())
           .subscribe(observer);
}