Android 之路 (4) – 对RxJava2的简单封装

前言

上篇对Retrofit进行了封装,本篇将继续深入对RxJava2的线程转换、取消订阅和统一订阅结果管理相关的封装。

正文

线程转换

以下代码基本上在每个Presenter中都会使用到,每次都要重新写就比较繁琐了,而RxJava提供 compose 方法可以进行合并,具体请看 这里 ,我可没写得他好….

.subscribeOn(Schedulers.io())//运行在io线程
.observeOn(AndroidSchedulers.mainThread())//回调在主线程

将以下代码加入到BaseApi中,方便每次调用:

/**
 * 统一线程处理
 *
 * @param <T> 泛型
 * @return
 */
public static <T> FlowableTransformer<T, T> getScheduler() {    //compose简化线程
	return new FlowableTransformer<T, T>() {
		@Override
		public Flowable<T> apply(Flowable<T> observable) {
			return observable.subscribeOn(Schedulers.io())
					.observeOn(AndroidSchedulers.mainThread());
		}
	};
}

在LoginPresenter中进行调用:

Android 之路 (4) - 对RxJava2的简单封装

取消订阅

在Presenter中只进行了了 == Disposable #f44336== 的订阅,但是对 Disposable 的取消订阅却没有做,如果我们在网络请求没完成的情况下关闭 Activity 或者 Fragment,就会造成 内存泄露 , 所以我们需要在 onDestroy 的时候取消订阅。

我这里的实现思路是将 Disposable 放到 BasePresenter 中,对外开放一个 unDisposable 的方法取消订阅。

BasePresenter

/**
 * 基类Presenter,做统一的处理
 */
public abstract class BasePresenter {
    /**
     * 持有订阅
     */
    protected Disposable mDisposable;

    /**
     * 取消订阅
     */
    public void unDisposable() {
        if (mDisposable != null) {
            mDisposable.dispose();
        }
    }
}

更改继承和订阅

将LoginContract.Presenter继承BasePresenter,然后再 LoginPresenter 中赋值订阅后的结果

Android 之路 (4) - 对RxJava2的简单封装

在LoginActivity 中取消订阅

@Override
protected void onDestroy() {
	super.onDestroy();
	mLoginPresenter.unDisposable();
}

至此简单完成了订阅和取消订阅的封装。

统一订阅处理

在进行subscribeWith订阅的时候,我们使用的是ResourceSubscriber这个抽象类,而又必须实现 onNext #f44336onErroronComplete 这三个方法,但事实上我们只需要关注结果 onNext 方法,另外的 onErroronComplete ==都可以进行统一的处理,不必每次都进行重写。

创建BaseView

创建一个BaseView,定义两个接口:

/**
 * 基类View,对统一的接口进行定义
 */
public interface BaseView {
    /**
     * 回调失败信息
     *
     * @param message 失败消息
     */
    void onFailure(String message);

    /**
     * 完成网络请求,可以在这个方法中关闭弹出等操作
     */
    void onComplete();
}

创建ApiSubscriber

创建抽象类ApiSubscriber继承至ResourceSubscriber,在ApiSubscriber中持有BaseView,实现 onErroronComplete 这两个方法。

/**
 * 统一订阅管理
 *
 * @param <T> 泛型
 */
public abstract class ApiSubscriber<T> extends ResourceSubscriber<T> {
    private BaseView view;

    public ApiSubscriber(BaseView view) {
        this.view = view;
    }

    public ApiSubscriber() {
    }

    @Override
    public void onError(Throwable t) {
        if (null != view) {
            view.onFailure(t.getMessage());
        }
    }

    @Override
    public void onComplete() {
        if (null != view) {
            view.onComplete();
        }
    }
}

更改订阅对象

将ResourceSubscriber更换成我们的ApiSubscriber抽象类。

/**
 * 登陆Presenter
 */
public class LoginPresenter extends LoginContract.Presenter {

    private String TAG = "LoginPresenter";

    public LoginPresenter(LoginContract.View view) {
        super(view);
    }

    @Override
    public void login(String userName, String password) {
        // 取消上次请求
        unDisposable();
        // 开始请求
        mDisposable = ServiceBuild.getUserService()
                .login(userName, password)
                .compose(BaseApi.<LoginDto>getScheduler())
                .subscribeWith(new ApiSubscriber<LoginDto>() {
                    @Override
                    public void onNext(LoginDto loginDto) {
                        //结果回调
                        Log.e(TAG, "onNext: " + loginDto);
                        if (loginDto.getCode() == 200) {
                            view.loginSuccess(loginDto);
                        } else {
                            view.loginFailure(loginDto.getMessage());
                        }
                    }
                });
    }
}

至于运行效果我们就不查看了,肯定是一致的,不信可以下载源码进行查看

结束

总结

本篇完成了对RxJava2的线程转换、取消订阅和统一订阅结果管理相关的封装,我们的代码又简洁了一部分、需要重复操心的部分也减少了一点,这也是一个大大的进步。

至此,我们的RxJava和Retrofit封装暂停一篇,下篇将先对 Dialog 进行封装,敬请期待。

源码

软广

一个痴心妄想想成为一个全屏(栈)工程师程序猿

来来,关注一下吧!

Android 之路 (4) - 对RxJava2的简单封装

原文 

http://fullscreendeveloper.cn/articles/2018/10/11/1539255083332.html

本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。

PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处:Harries Blog™ » Android 之路 (4) – 对RxJava2的简单封装

赞 (0)
分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址