前面写了一篇从实现到封装一个MVP,但是每次新建一个Act都要重建许多文件，因此封装一个通用的IBaseView，BaseModule，BasePresenter能省很多时间。
通用的module
我的module是在act执行oncreate方法中初始化好的BasePresenter中持有retrofit的ApiManager。
public class BasePresenter<M extends BaseModule, V extends BaseContract.IBaseView> {
protected M module;
protected V view;
protected Context context;
ApiManager apiManager;
protected ApiManager getApiManager() {
if(apiManager==null){
return new Retrofit.Builder().baseUrl("http://www.eltyl.com/")
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.addConverterFactory(GsonConverterFactory.create()).build().create(ApiManager.class);
}else {
return apiManager;
}
}
void attatchWindow(M m, V v) {
this.module = m;
this.view = v;
}
void detachWindow() {
this.module = null;
this.view = null;
}
在presenter调用的时候只需要这样
module.getData(getApiManager().test2(), new IPresenterI<LoginBean>() {
@Override
public void onResult(LoginBean loginBean) {
}
@Override
public void onError(String s) {
}
});
protected abstract class IPresenterI<T extends BaseBean> implements DefaultContract.IDefaultPresenter<T> {
@Override
public void onStart() {
view.showLoading();
}
@Override
public void onComplete() {
view.cancelLoading();
}
}
public interface IDefaultModule extends IBaseModule {
<T extends BaseBean> void getData(Observable<T> observable, IDefaultPresenter<T> normalPresenter);
}
public interface IDefaultPresenter<T extends BaseBean> extends IBasePresenter {
void onResult(T t);
void onStart();
void onComplete();
void onError(String s);
}
public interface ApiManager {
@GET("index.php?s=/appi/news/getNewsCat")
Observable<BaseBean> test1();
@GET("index.php?s=/appi/news/getNewsCat")
Observable<LoginBean> test2();
}
重写实现了IPresent的2个方法，因为start的时候一般都会启动loading框动画，结束的时候关掉。。presenter只需要关心拿到结果和出错两种情况。
module中的getData方法实现，getData方法持有一个Bean对象他继承自BaseBean,同时在initObservable(observable,normalPresenter)中封装了io线程和主线程的切换，还有在doOnSubscribe()的时候开启loading
public class DefaultModule extends BaseModule implements DefaultContract.IDefaultModule {
@Override
public <T extends BaseBean> void getData(Observable<T> observable, final DefaultContract.IDefaultPresenter<T> normalPresenter) {
initObservable(observable, normalPresenter).subscribe(new Observer<T>() {
@Override
public void onSubscribe(@NonNull Disposable disposable) {
}
@Override
public void onNext(@NonNull T t) {
normalPresenter.onResult(t);
}
@Override
public void onError(@NonNull Throwable throwable) {
normalPresenter.onError(throwable.toString());
}
@Override
public void onComplete() {
normalPresenter.onComplete();
}
});
}
}
public class BaseModule implements BaseContract.IBaseModule {
protected <T extends BaseBean> Observable<T> initObservable(Observable<T> observable, final DefaultContract.IDefaultPresenter presenter){
return observable.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).doOnSubscribe(new Consumer<Disposable>() {
@Override
public void accept(@NonNull Disposable disposable) throws Exception {
presenter.onStart();
}
});
}
}
整体代码如下
module.getData(getApiManager().test2(), new IPresenterI<LoginBean>() {
@Override
public void onResult(LoginBean baseBean) {
}
@Override
public void onError(String s) {
}
});
public interface ApiManager {
@GET("index.php?s=/appi/news/getNewsCat")
Observable<BaseBean> test1();
@GET("index.php?s=/appi/news/getNewsCat")
Observable<LoginBean> test2();
}
protected abstract class IPresenterI<T extends BaseBean> implements DefaultContract.IDefaultPresenter<T> {
@Override
public void onStart() {
view.showLoading();
}
@Override
public void onComplete() {
view.cancelLoading();
}
}
public class DefaultModule extends BaseModule implements DefaultContract.IDefaultModule {
@Override
public <T extends BaseBean> void getData(Observable<T> observable, final DefaultContract.IDefaultPresenter<T> normalPresenter) {
initObservable(observable, normalPresenter).subscribe(new Observer<T>() {
@Override
public void onSubscribe(@NonNull Disposable disposable) {
}
@Override
public void onNext(@NonNull T t) {
normalPresenter.onResult(t);
}
@Override
public void onError(@NonNull Throwable throwable) {
normalPresenter.onError(throwable.toString());
}
@Override
public void onComplete() {
normalPresenter.onComplete();
}
});
}
}
public interface IDefaultModule extends IBaseModule {
<T extends BaseBean> void getData(Observable<T> observable, IDefaultPresenter<T> normalPresenter);
}
public interface IDefaultPresenter<T extends BaseBean> extends IBasePresenter {
void onResult(T t);
void onStart();
void onComplete();
void onError(String s);
}
public class BaseModule implements BaseContract.IBaseModule {
protected <T extends BaseBean> Observable<T> initObservable(Observable<T> observable, final DefaultContract.IDefaultPresenter presenter){
return observable.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).doOnSubscribe(new Consumer<Disposable>() {
@Override
public void accept(@NonNull Disposable disposable) throws Exception {
presenter.onStart();
}
});
}
}
