用户版首頁mvp绑定view

m-home/src/ydl/java/com/yidianling/home/presenter/HomePresenterImpl.kt

@@ -3,6 +3,7 @@ package com.yidianling.home.presenter
 import android.annotation.SuppressLint
 import com.google.gson.Gson
 import com.ydl.ydlcommon.base.BaseApp
+import com.ydl.ydlcommon.data.http.RxUtils
 import com.ydl.ydlcommon.data.http.ThrowableConsumer
 import com.ydl.ydlcommon.modular.ModularServiceManager
 import com.ydl.ydlcommon.utils.SharedPreferencesEditor
@@ -42,7 +43,8 @@ class HomePresenterImpl: BaseHomePresenterImpl<IHomeContract.View, IHomeContract
         val homeList: MutableList<HomePagerDataBean> = mutableListOf()
         LogUtil.d("mConsultType-loadHomeData:$mConsultType")
         Observable.mergeArray(
-            mModel.headerRequest().map { it ->
+            mModel.headerRequest()
+                .compose(RxUtils.applySchedulers(mView)).map { it ->
                 //首页头部数据 分类 & Banner
                 homeList.add(
                     getHomeItemFromTempData(
@@ -64,20 +66,24 @@ class HomePresenterImpl: BaseHomePresenterImpl<IHomeContract.View, IHomeContract
                     ModularServiceManager.provide(IConsultantService::class.java).setHotSearch(it)
                 }
             },
-            mModel.consultRequest(mConsultType).map {
+            mModel.consultRequest(mConsultType)
+                .compose(RxUtils.applySchedulers(mView)).map {
                 //首页咨询数据
                 homeList.add(getHomeItemFromTempData(it, YdlHomeViewHolderConstract.CONSULT_VIEW))
             },
             //GoodType为空 获取默认类型
-            mModel.confideRequest(mConfideType).map {
+            mModel.confideRequest(mConfideType)
+                .compose(RxUtils.applySchedulers(mView)).map {
                 //首页倾述数据
                 homeList.add(getHomeItemFromTempData(it, YdlHomeViewHolderConstract.CONFIDE_VIEW))
             },
-            mModel.courseRequest().map {
+            mModel.courseRequest()
+                .compose(RxUtils.applySchedulers(mView)).map {
                 //首页课程数据
                 homeList.add(getHomeItemFromTempData(it, YdlHomeViewHolderConstract.COURSE_VIEW))
             },
-            mModel.testRequest().map {
+            mModel.testRequest()
+                .compose(RxUtils.applySchedulers(mView)).map {
                 //首页测试数据
                 val homeTestBean = HomeTestBean()
                 homeTestBean.testItemList = it.data
@@ -88,7 +94,8 @@ class HomePresenterImpl: BaseHomePresenterImpl<IHomeContract.View, IHomeContract
                     )
                 )
             },
-            mModel.askRequest().map {
+            mModel.askRequest()
+                .compose(RxUtils.applySchedulers(mView)).map {
                 //首页问答数据
                 homeList.add(
                     getHomeItemFromTempData(
@@ -97,11 +104,13 @@ class HomePresenterImpl: BaseHomePresenterImpl<IHomeContract.View, IHomeContract
                     )
                 )
             },
-            mModel.museRequest().map {
+            mModel.museRequest()
+                .compose(RxUtils.applySchedulers(mView)).map {
                 //首页冥想数据
                 homeList.add(getHomeItemFromTempData(it, YdlHomeViewHolderConstract.MUSE_VIEW))
             },
-            mModel.fmRequest().map {
+            mModel.fmRequest()
+                .compose(RxUtils.applySchedulers(mView)).map {
                 //首页电台数据
                 homeList.add(
                     getHomeItemFromTempData(
@@ -110,7 +119,8 @@ class HomePresenterImpl: BaseHomePresenterImpl<IHomeContract.View, IHomeContract
                     )
                 )
             },
-            mModel.articleRequest().map {
+            mModel.articleRequest()
+                .compose(RxUtils.applySchedulers(mView)).map {
                 //首页文章数据
                 homeList.add(getHomeItemFromTempData(it, YdlHomeViewHolderConstract.ARTICLE_VIEW))
                 homeList.add(HomePagerDataBean(YdlHomeViewHolderConstract.FOOTER_VIEW))