Rxjava和Retrofit结合使用的案例

//这里返回了被观察者observable对象
public interface CategoryService{
@GET("/category/query")
Observable<Catogory> getArticalCategoryData(@Query("key") String key);

}

private void initData() {
LoadingCustom.showprogress(this,"正在加载数据",true);
Retrofit retrofit=new Retrofit.Builder()
.baseUrl(URLDefine.BaseUrl)

.addCallAdapterFactory(RxJavaCallAdapterFactory.create())
.addConverterFactory(GsonConverterFactory.create())
.build();
CategoryService service = retrofit.create(CategoryService.class);
rx.Observable<Catogory> observable = service.getArticalCategoryData(URLDefine.KEY);

observable
.subscribeOn(Schedulers.io())

.subscribe(new Subscriber<Catogory>() {
@Override
public void onCompleted() {

}

@Override
public void onError(Throwable e) {

}

@Override
public void onNext(Catogory catogory) {
if (catogory!=null){
getData(catogory);
}
}
});
}
4000
>

到这里结合就基本实现了,剩余的工作,基本上是不断的优化封装,为我们具体的项目做具体的私人定制封装

关于Retrofit的API service接口的使用方式请查看另一篇博客

http://blog.csdn.net/sinat_35670989/article/details/55095336