模块化解耦框架RxFluxArchitecture2-基本功能实现

相关系列文章

模块化解耦框架RxFluxArchitecture1-框架简介

模块化解耦框架RxFluxArchitecture2-基本功能实现

模块化解耦框架RxFluxArchitecture3-订阅管理绑定生命周期

模块化解耦框架RxFluxArchitecture4-依赖库与依赖注入

模块化解耦框架RxFluxArchitecture5-Application多模块共存

架构图

一、操做结果通知RxAction和UI响应通知RxChange

1.一、View 调用

在LoginFragment点击登陆按钮，调用LoginActionCreator中的方法login(String,String)。

@OnClick(R2.id.btn_login)
    public void login() {
        mActionCreator.login(username, password);
    }
复制代码

1.二、ActionCreator 操做并发送

在LoginActionCreator的方法login(String,String)中postHttpAction(RxAction, Observable<T>)方法会调用WanApi接口方法进行登陆操做，登陆完成后发送封装接口返回结果的RxAction（包含TagLoginAction.LOGIN）。

@Override
    public void login(String username, String password) {
        RxAction rxAction = newRxAction(LoginAction.LOGIN);
        postHttpAction(rxAction, mWanApi.login(username, password).flatMap(verifyResponse()));
    }
复制代码

1.三、Store 接收并发送

在LoginStore中接收 Tag 为LoginAction.LOGIN，数据类型为RxAction的通知。取出RxAction中封装的接口返回数据，而后使用方法postChange(RxChange)通知 View 进行 UI 响应操做。

@Subscribe(tags = {LoginAction.LOGIN})
    public void onLogin(RxAction rxAction) {
        mUser = rxAction.getResponse();
        postChange(RxChange.newInstance(rxAction.getTag()));
    }
复制代码

1.四、View 接收

在LoginActivity中接收Tag为LoginAction.LOGIN，数据类型为RxChange的通知，进行 UI 更新操做。

@Subscribe(tags = {LoginAction.LOGIN}, sticky = true)
    public void onLogin(RxChange rxChange) {
        startActivity(new Intent(this, ArticleActivity.class));
        finish();
    }
复制代码

二、操做进度通知RxLoading

2.一、ActionCreator 操做并发送

在LoginActionCreator中使用postHttpLoadingAction(RxAction, Observable<T>)方法。 操做开始时，发送进度开始通知RxLoading； 操做完成，发送封装接口返回结果的RxAction（包含TagLoginAction.LOGIN）； 操做结束后，发送进度结束通知RxLoading。

@Override
    public void login(String username, String password) {
        RxAction rxAction = newRxAction(LOGIN);
        postHttpLoadingAction(rxAction, mWanApi.login(username, password).flatMap(verifyResponse()));
    }
复制代码

2.二、View 接收

2.2.一、全局接收

在BaseActivity中全局响应RxLoading，全部子类 Activity 都会在接收到RxLoading通知后，调用onRxLoading(RxLoading)(方法名可变)。

@Subscribe(sticky = true)
    public void onRxLoading(@NonNull RxLoading rxLoading) {
        if (rxLoading.isLoading()) {
            //显示进度框
        } else {
            //隐藏进度框
        }
    }
复制代码

2.2.二、单独接收

在BaseActivity子类LoginActivity中重写onRxLoading(RxLoading)方法，单独响应Tag为LoginAction.LOGIN的RxLoading。

@Override
    @Subscribe(sticky = true)
    public void onRxLoading(@NonNull RxLoading rxLoading) {
        if (TextUtils.equals(rxLoading.getTag(), LoginAction.LOGIN)) {
            if (rxLoading.isLoading()) {
                //显示进度框
            } else {
                //隐藏进度框
            }
        } else {
            super.onRxLoading(rxLoading);
        }
    }
复制代码

三、 操做异常通知RxError

3.一、ActionCreator 操做并发送

在RxActionCretor 中postHttpAction(RxAction, Observable<T>)和postHttpLoadingAction(RxAction, Observable<T>)方法，若是有异常，会发送操做异常通知RxError。

3.二、View 接收

3.2.一、全局接收

在BaseActivity中全局响应RxError，全部子类 Activity 都会在接收到RxError通知后，调用onRxError(RxError)(方法名可变)。

@Subscribe(sticky = true)
    public void onRxError(@NonNull RxError rxError) {
        Throwable throwable = rxError.getThrowable();
        if (throwable instanceof CommonException) {
            Toast.makeText(this, ((CommonException) throwable).message(), Toast.LENGTH_SHORT).show();
        } else if (throwable instanceof retrofit2.HttpException) {
            Toast.makeText(this, ((retrofit2.HttpException) throwable).code() + ":服务器问题", Toast.LENGTH_SHORT).show();
        } else if (throwable instanceof SocketException) {
            Toast.makeText(this, "网络异常!", Toast.LENGTH_SHORT).show();
        } else if (throwable instanceof UnknownHostException) {
            Toast.makeText(this, "网络异常!", Toast.LENGTH_SHORT).show();
        } else if (throwable instanceof SocketTimeoutException) {
            Toast.makeText(this, "链接超时!", Toast.LENGTH_SHORT).show();
        } else {
            Toast.makeText(this, throwable.toString(), Toast.LENGTH_SHORT).show();
        }
    }
复制代码

3.2.二、单独接收

在BaseActivity子类LoginActivity中重写onRxError(RxError)方法，单独响应Tag为LoginAction.LOGIN的RxError。

@Override
    @Subscribe(sticky = true)
    public void onRxError(@NonNull RxError rxError) {
        if (TextUtils.equals(rxError.getTag(), LoginAction.LOGIN)) {
           //单独处理操做异常...
        } else {
            super.onRxError(rxError);
        }
    }
复制代码

四、操做异常重试通知RxRtry

4.一、ActionCreator 操做并发送

在FriendActionCreator中使用postHttpRetryAction(RxAction, Observable<T>)方法，若是操做有异常，会发送异常重试通知RxRetry。

@Override
    public void getFriendList() {
        RxAction rxAction = newRxAction(FriendAction.GET_FRIEND_LIST);
        postHttpRetryAction(rxAction, mWanApi.getFriendList());
    }
复制代码

4.二、View 接收

4.2.一、全局接收

在BaseActivity中全局响应RxRetry，全部子类 Activity 都会在接收到RxRetry通知后，调用onRxRetry(RxRetry)(方法名可变)。在该方法中，能够使用RxActionCreator中的postRetryAction(RxRetry)方法重试。

@Subscribe(sticky = true)
    public void onRxRetry(@NonNull RxRetry rxRetry) {
        CoordinatorLayout coordinatorLayout = findViewById(R.id.cdl_content);
        if (coordinatorLayout == null) {
            return;
        }
        Snackbar snackbar = Snackbar.make(coordinatorLayout, rxRetry.getTag(), Snackbar.LENGTH_INDEFINITE);
        snackbar.setAction("Retry", v -> mCommonActionCreatorLazy.get().postRetryAction(rxRetry)).show();
    }
复制代码

4.2.二、单独接收

在BaseActivity子类中重写onRxRetry(RxRetry)方法，单独响应特定 Tag 的RxRetry。

@Override
    @Subscribe(sticky = true)
    public void onRxRetry (@NonNull RxRetry rxRetry) {
        if (TextUtils.equals(rxRetry.getTag(), FriendAction.GET_FRIEND_LIST)) {
            //单独处理异常重试...
        } else {
            super.onRxRetry(rxRetry);
        }
    }
复制代码

源码

开源模块化解耦框架RxFluxArchitecture，欢迎你们点赞Fork，更欢迎点评指导。