Android开发

Android真响应式架构——MvRx和Epoxy的结合

2019-02-14  本文已影响179人  珞泽珈群

前言

Android真响应式架构系列文章:

Android真响应式架构——MvRx
Epoxy——RecyclerView的绝佳助手
Android真响应式架构——Model层设计
Android真响应式架构——数据流动性
Android真响应式架构——Epoxy的使用
Android真响应式架构——MvRx和Epoxy的结合

之前的文章讲了MvRx,讲了Epoxy,但是却没有讲MvRx是怎么跟Epoxy结合起来的。这篇文章就来讲讲MvRx和Epoxy是怎么结合在一起进而实现数显两开花的(前面都省略掉,不管了直接开花吧)。

这是这个系列文章的最后一篇了,本意是想写一篇MvRx在一个复杂界面上的实践的,但是,我发现这个实例有点复杂,并且牵扯到过多的业务细节,很难讲清楚,所以就放弃了。

1. MvRx和Epoxy结合

在MvRx的sample中已经展示了如何使用Epoxy,还是很简单的。

abstract class BaseFragment : BaseMvRxFragment() {

    //Epoxy扩展的 RecyclerView,第二篇文章中讲过
    protected lateinit var recyclerView: EpoxyRecyclerView
    
    protected val epoxyController by lazy { epoxyController() }

    //ViewModel中 State的任意改变都会调用该方法,这里也仅仅是通知 EpoxyController重建 Model
    override fun invalidate() {
        recyclerView.requestModelBuild()
    }

    abstract fun epoxyController(): ToDoEpoxyController
}

class ToDoEpoxyController(
    val buildModelsCallback: EpoxyController.() -> Unit = {}
) : AsyncEpoxyController() { //AsyncEpoxyController,异步的 EpoxyController,Model的构建及diff均在子线程中,第二篇文章中讲过
    override fun buildModels() {
        //委托给我们传递进来的 EpoxyController的扩展函数
        buildModelsCallback()
    }
}

代码很简单,关键就是如何在子类中实现buildModelsCallback。继续往下看:


/**
 * Create a [ToDoEpoxyController] that builds models with the given callback.
 * When models are built the current state of the viewmodel will be provided.
 * 嗯,你看人家说的多好,就是这个意思。。。
 */
fun <S : MvRxState, A : MvRxViewModel<S>> BaseFragment.simpleController(
    viewModel: A,
    buildModels: EpoxyController.(state: S) -> Unit
) = ToDoEpoxyController {
    //构建Models是异步的,可能fragment已经不存在
    if (view == null || isRemoving) return@ToDoEpoxyController
    //MvRx给我们提供的 withState方法,线程安全,可以获取当前的 State,便于我们构建Models
    withState(viewModel) { state ->
        buildModels(state)
    }
}

//两个ViewModel,如果你需要更多个ViewModel,可以继续扩展
fun <A : BaseMvRxViewModel<B>, B : MvRxState, C : BaseMvRxViewModel<D>, D : MvRxState> BaseFragment.simpleController(
    viewModel1: A,
    viewModel2: C,
    buildModels: EpoxyController.(state1: B, state2: D) -> Unit
) = ToDoEpoxyController {
    if (view == null || isRemoving) return@ToDoEpoxyController
    withState(viewModel1, viewModel2) { state1, state2 ->
        buildModels(state1, state2)
    }
}

/**
 * 具体某个Fragment的实现
 */
class TaskListFragment : BaseFragment() {

    private val taskListViewModel: TaskListViewModel by fragmentViewModel()

    override fun epoxyController() = simpleController(viewModel, taskListViewModel) { state, taskListState ->
        //Epoxy生成的EpoxyModel,使用Kotlin的情况下可以采用这种DSL的写法
        horizontalLoader {
            id("loader")
            loading(state.isLoading)
        }

        //...
    }
}

simpleController的帮助下,获取当前State,并且重建EpoxyModels即可。Epoxy负责界面的响应式,MvRx实现状态的管理,双剑合璧,相得益彰。

2. 显示Loading

MvRx给的sample中,Loading也是作为RecyclerView的一个item管理的。这固然是为了界面管理的统一,但是又有点矫枉过正了。一般情况下,我们还是希望Loading以浮动的形式呈现。前文提到MvRx使用Async来表示数据的加载状态,我们可以通过观察State中的Async属性来显示Loading。以下是我的实践:

//定义State的基类,所有State都包含属性repoAsync
interface BaseState : MvRxState {
    val repoAsync: Async<Any> //仅仅是为了显示Loading,泛型指定为Any
}

abstract class BaseViewModelFragment<S : BaseState, VM : BaseMvRxViewModel<S>> : BaseMvRxFragment() {
    //主ViewModel,Fragment可以包含有多个View,但是这个ViewModel有显示Loading的作用
    protected abstract val viewModel: VM

    override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
        super.onViewCreated(view, savedInstanceState)
        viewModel.subscribe { state ->
            if (state.repoAsync is Loading) {
                //显示Loading
                startLoading()
            } else if (state.initAsync.complete || state.repoAsync.complete) { //Async包含complete属性,Success或者Fail的情况下为 true
                //取消Loading
                stopLoading()
                if (state.repoAsync is Fail) {
                    //处理失败信息
                    handleFail((state.repoAsync as Fail<Any>).error)
                }
            }
        }
    }
}

data class SomeState(...) : BaseState

class SomeViewModel(initialState: SomeState, private val repo: DataRepository) : BaseMvRxViewModel<SomeState>(initialState) {
    fun fetchData() {
        repo.fetchData() //假设返回的是Observable
            .excute {
                //把it(即Async)赋值给repoAsync就会显示Loading;不需要显示Loading,不赋值即可
                copy(repoAsync = it, ...)
            }
    }
}

如上,通过State基类中的repoAsync属性,统一控制Loading的显示。需要显示Loading的请求,对repoAsync赋值即可(前提得是主ViewModel);不需要显示Loading,不赋值即可。

总结

没啥好总结的,一目了然。好吧,这一系列文章终于写完了,欢迎留言与我交流。

上一篇 下一篇

猜你喜欢

热点阅读