Retrofit2+RxJava

Retrofit2+RxJava

1.定义接口

interface city {
@GET("openapi/cities")
Observable<City> getCitiesBean();
}

2.Subscriber

city.getCitiesBean()
.subscribeOn(Schedulers.io())//指定网络加载等操作在I/0线程
.observeOn(AndroidSchedulers.mainThread())//更新页面在主线程，符合业务逻辑
.map(new Func1<City, List<City.CitiesBean>>() {

@Override
public List<City.CitiesBean> call(City city) {
return city.getCities();
}
})//Func1是一个带返回值的包装，map是对Observable进行转换
.flatMap(new Func1<List<City.CitiesBean>, Observable<String>>() {
@Override
public Observable<String> call(List<City.CitiesBean> citiesBeen) {
return Observable.just(citiesBeen.get(1).getCity_name());
}//subscribe是订阅，其中Action1是一个封装了OnNext的
}).subscribe(new Action1<String>() {
//flatMap也是一种转换，是对多个对象进行转换，返回的必须是一个Observable，然后再进行订阅，接受到的新的
//订阅再进行subscribe订阅，然后操作的是这个新的Observable。相当于A->C变成A->B,B->C这样铺平。也就是
//flat的含义。
@Override
public void call(String s) {
Log.v("aaaaaaaaa",s);
}
});

new Observer<String>() {
@Override
public void onCompleted() {

}

@Override
public void onError(Throwable e) {

}

@Override
public void onNext(String s) {

}
}

3.取消订阅，Subscriber.unsubcribe();