导入依赖:
implementation 'io.reactivex:rxjava:1.0.14'
implementation 'io.reactivex:rxandroid:1.0.1'
implementation 'com.squareup.retrofit2:retrofit:2.0.2'
implementation 'com.squareup.retrofit2:converter-gson:2.0.2'
implementation 'com.squareup.retrofit2:adapter-rxjava:2.0.2'
配置service
public interface MyService {
@GET("umIPmfS6c83237d9c70c7c9510c9b0f97171a308d13b611")
Observable<GoodBean> getGoods(@QueryMap Map<String, String> map);
}
m层写入map集合存放数据
ModelImpel
public class ModelImpel implements IModel {
private static final String TAG = "ModelImpel---";
private final IPresenter iPresenter;
public ModelImpel(IPresenter iPresenter){
this.iPresenter = iPresenter;
}
@Override
public void getGoodsData(Map<String, String> map) {
RetrofitUtils retrofitUtils = RetrofitUtils.getInstance ();
MyService myService = retrofitUtils.createRequest (MyService.class);
Observable<GoodBean> observable = myService.getGoods (map);
observable.subscribeOn (Schedulers.newThread ())
.observeOn (AndroidSchedulers.mainThread ())
.subscribe (new Observer<GoodBean> () {
@Override
public void onCompleted() {
Log.d (TAG, "onCompleted: "+"完成");
}
@Override
public void onError(Throwable e) {
Log.d (TAG, "onError: "+e.getMessage ());
}
@Override
public void onNext(GoodBean goodBean) {
iPresenter.ShowGoodData (goodBean.getData ().getSubjects ());
}
});
}
}