引入RxLifecycle防止rx的内存泄漏，通过扩展方法的方式对代码进行优化。

Author: hydcoder

BaseLibrary/build.gradle

@@ -58,4 +58,8 @@ dependencies {
     api "com.google.dagger:dagger:$dagger_version"
     kapt "com.google.dagger:dagger-compiler:$dagger_version"
 
+    //RxLifecycle
+    api "com.trello:rxlifecycle-kotlin:$rx_lifecycle_version"
+    api "com.trello:rxlifecycle-components:$rx_lifecycle_version"
+
 }

BaseLibrary/src/main/java/com/hyd/base/ext/CommonExts.kt

@@ -1,6 +1,11 @@
 package com.hyd.base.ext
 
+import android.view.View
+import com.hyd.base.data.protocal.BaseResp
+import com.hyd.base.rx.BaseFunc
+import com.hyd.base.rx.BaseFuncBoolean
 import com.hyd.base.rx.BaseSubscribe
+import com.trello.rxlifecycle.LifecycleProvider
 import rx.Observable
 import rx.android.schedulers.AndroidSchedulers
 import rx.schedulers.Schedulers
@@ -9,8 +14,25 @@ import rx.schedulers.Schedulers
  * Created by hydCoder on 2019/7/16.
  * 以梦为马，明日天涯。
  */
-fun <T> Observable<T>.execute(subscriber: BaseSubscribe<T>) {
+fun <T> Observable<T>.execute(subscriber: BaseSubscribe<T>, lifecycleProvider: LifecycleProvider<*>) {
     this.observeOn(AndroidSchedulers.mainThread())
+        .compose(lifecycleProvider.bindToLifecycle())
         .subscribeOn(Schedulers.io())
         .subscribe(subscriber)
+}
+
+fun <T> Observable<BaseResp<T>>.convert(): Observable<T> {
+    return this.flatMap(BaseFunc())
+}
+
+fun <T> Observable<BaseResp<T>>.convertBoolean(): Observable<Boolean> {
+    return this.flatMap(BaseFuncBoolean())
+}
+
+fun View.onClick(listener: View.OnClickListener) {
+    this.setOnClickListener(listener)
+}
+
+fun View.onClick(method: () -> Unit) {
+    this.setOnClickListener { method }
 }

BaseLibrary/src/main/java/com/hyd/base/injection/component/ActivityComponent.kt

@@ -1,17 +1,21 @@
 package com.hyd.base.injection.component
 
 import android.app.Activity
+import android.content.Context
 import com.hyd.base.injection.ActivityScope
 import com.hyd.base.injection.module.ActivityModule
+import com.hyd.base.injection.module.LifecycleProviderModule
+import com.trello.rxlifecycle.LifecycleProvider
 import dagger.Component
 
 /**
  * Created by hydCoder on 2019/7/17.
  * 以梦为马，明日天涯。
  */
 @ActivityScope
-@Component(dependencies = arrayOf(AppComponent::class), modules = arrayOf(ActivityModule::class))
+@Component(dependencies = arrayOf(AppComponent::class), modules = arrayOf(ActivityModule::class, LifecycleProviderModule::class))
 interface ActivityComponent {
-
     fun activity(): Activity
+    fun context() : Context
+    fun lifecycleProvider(): LifecycleProvider<*>
 }

BaseLibrary/src/main/java/com/hyd/base/injection/module/LifecycleProviderModule.kt

@@ -0,0 +1,18 @@
+package com.hyd.base.injection.module
+
+import com.trello.rxlifecycle.LifecycleProvider
+import dagger.Module
+import dagger.Provides
+
+/**
+ * Created by hydCoder on 2019/7/17.
+ * 以梦为马，明日天涯。
+ */
+@Module
+class LifecycleProviderModule(private val lifecycleProvider: LifecycleProvider<*>) {
+
+    @Provides
+    fun providesLifecycleProvider(): LifecycleProvider<*> {
+        return lifecycleProvider
+    }
+}

BaseLibrary/src/main/java/com/hyd/base/presenter/BasePresenter.kt

@@ -1,7 +1,12 @@
 package com.hyd.base.presenter
 
 import com.hyd.base.presenter.view.BaseView
+import com.trello.rxlifecycle.LifecycleProvider
+import javax.inject.Inject
 
 open class BasePresenter<T:BaseView> {
     lateinit var mView: T
+
+    @Inject
+    lateinit var lifecycleProvider: LifecycleProvider<*>
 }

BaseLibrary/src/main/java/com/hyd/base/rx/BaseFunc.kt

@@ -0,0 +1,18 @@
+package com.hyd.base.rx
+
+import com.hyd.base.data.protocal.BaseResp
+import rx.Observable
+import rx.functions.Func1
+
+/**
+ * Created by hydCoder on 2019/7/18.
+ * 以梦为马，明日天涯。
+ */
+class BaseFunc<T>: Func1<BaseResp<T>, Observable<T>> {
+    override fun call(t: BaseResp<T>): Observable<T> {
+        if (t.status != 0) {
+            return Observable.error(BaseException(t.status, t.message))
+        }
+        return Observable.just(t.data)
+    }
+}

BaseLibrary/src/main/java/com/hyd/base/rx/BaseFuncBoolean.kt

@@ -0,0 +1,18 @@
+package com.hyd.base.rx
+
+import com.hyd.base.data.protocal.BaseResp
+import rx.Observable
+import rx.functions.Func1
+
+/**
+ * Created by hydCoder on 2019/7/18.
+ * 以梦为马，明日天涯。
+ */
+class BaseFuncBoolean<T>: Func1<BaseResp<T>, Observable<Boolean>> {
+    override fun call(t: BaseResp<T>): Observable<Boolean> {
+        if (t.status != 0) {
+            return Observable.error(BaseException(t.status, t.message))
+        }
+        return Observable.just(true)
+    }
+}

BaseLibrary/src/main/java/com/hyd/base/ui/activity/BaseActivity.kt

@@ -1,6 +1,6 @@
 package com.hyd.base.ui.activity
 
-import android.support.v7.app.AppCompatActivity
+import com.trello.rxlifecycle.components.support.RxAppCompatActivity
 
-open class BaseActivity : AppCompatActivity(){
+open class BaseActivity : RxAppCompatActivity(){
 }

BaseLibrary/src/main/java/com/hyd/base/ui/activity/BaseMvpActivity.kt

@@ -5,11 +5,12 @@ import com.hyd.base.common.BaseApplication
 import com.hyd.base.injection.component.ActivityComponent
 import com.hyd.base.injection.component.DaggerActivityComponent
 import com.hyd.base.injection.module.ActivityModule
+import com.hyd.base.injection.module.LifecycleProviderModule
 import com.hyd.base.presenter.BasePresenter
 import com.hyd.base.presenter.view.BaseView
 import javax.inject.Inject
 
-open class BaseMvpActivity<T:BasePresenter<*>>:BaseActivity(), BaseView{
+open abstract class BaseMvpActivity<T:BasePresenter<*>>:BaseActivity(), BaseView{
 
     lateinit var activityComponent: ActivityComponent
 
@@ -29,11 +30,14 @@ open class BaseMvpActivity<T:BasePresenter<*>>:BaseActivity(), BaseView{
         super.onCreate(savedInstanceState)
 
         initActivityInjection()
+        injectComponent()
     }
 
     private fun initActivityInjection() {
         activityComponent = DaggerActivityComponent.builder().appComponent((application as BaseApplication).appComponent)
-                .activityModule(ActivityModule(this)).build()
+                .activityModule(ActivityModule(this)).lifecycleProviderModule(LifecycleProviderModule(this)).build()
     }
 
+    abstract fun injectComponent()
+
 }

BaseLibrary/src/main/java/com/hyd/base/ui/fragment/BaseFragment.kt

@@ -0,0 +1,6 @@
+package com.hyd.base.ui.fragment
+
+import com.trello.rxlifecycle.components.support.RxFragment
+
+open class BaseFragment : RxFragment(){
+}

BaseLibrary/src/main/java/com/hyd/base/ui/fragment/BaseMvpFragment.kt

@@ -0,0 +1,43 @@
+package com.hyd.base.ui.fragment
+
+import android.os.Bundle
+import com.hyd.base.common.BaseApplication
+import com.hyd.base.injection.component.ActivityComponent
+import com.hyd.base.injection.component.DaggerActivityComponent
+import com.hyd.base.injection.module.ActivityModule
+import com.hyd.base.injection.module.LifecycleProviderModule
+import com.hyd.base.presenter.BasePresenter
+import com.hyd.base.presenter.view.BaseView
+import javax.inject.Inject
+
+open abstract class BaseMvpFragment<T:BasePresenter<*>>:BaseFragment(), BaseView{
+
+    lateinit var activityComponent: ActivityComponent
+
+    @Inject
+    lateinit var mPresenter: T
+
+    override fun showLoading() {
+    }
+
+    override fun hideLoading() {
+    }
+
+    override fun onError() {
+    }
+
+    override fun onCreate(savedInstanceState: Bundle?) {
+        super.onCreate(savedInstanceState)
+
+        initActivityInjection()
+        injectComponent()
+    }
+
+    private fun initActivityInjection() {
+        activityComponent = DaggerActivityComponent.builder().appComponent((activity?.application as BaseApplication).appComponent)
+                .activityModule(ActivityModule(activity!!)).lifecycleProviderModule(LifecycleProviderModule(this)).build()
+    }
+
+    abstract fun injectComponent()
+
+}

UserCenter/src/main/java/com/hyd/user/presenter/RegisterPresenter.kt

@@ -17,8 +17,9 @@ class RegisterPresenter @Inject constructor(): BasePresenter<RegisterView>() {
         userService.register(mobile, verifyCode, pwd)
             .execute(object : BaseSubscribe<Boolean>(){
                 override fun onNext(t: Boolean) {
-                    mView.onRegisterResult(t)
+                    if (t)
+                        mView.onRegisterResult("注册成功")
                 }
-            })
+            }, lifecycleProvider)
     }
 }

UserCenter/src/main/java/com/hyd/user/presenter/view/RegisterView.kt

@@ -3,5 +3,5 @@ package com.hyd.user.presenter.view
 import com.hyd.base.presenter.view.BaseView
 
 interface RegisterView: BaseView {
-    fun onRegisterResult(result:Boolean)
+    fun onRegisterResult(result: String)
 }

UserCenter/src/main/java/com/hyd/user/service/impl/UserServiceImpl.kt

@@ -1,11 +1,9 @@
 package com.hyd.user.service.impl
 
-import com.hyd.base.data.protocal.BaseResp
-import com.hyd.base.rx.BaseException
+import com.hyd.base.ext.convertBoolean
 import com.hyd.user.data.repository.UserRepository
 import com.hyd.user.service.UserService
 import rx.Observable
-import rx.functions.Func1
 import javax.inject.Inject
 
 /**
@@ -19,13 +17,6 @@ class UserServiceImpl @Inject constructor(): UserService {
 
     override fun register(mobile: String, verifyCode: String, pwd: String): Observable<Boolean> {
 
-        return repository.register(mobile, verifyCode, pwd).flatMap(object : Func1<BaseResp<String>, Observable<Boolean>>{
-            override fun call(t: BaseResp<String>): Observable<Boolean> {
-                if (t.status != 0) {
-                    return Observable.error(BaseException(t.status, t.message))
-                }
-                return Observable.just(true)
-            }
-        })
+        return repository.register(mobile, verifyCode, pwd).convertBoolean()
     }
 }

UserCenter/src/main/java/com/hyd/user/ui/activity/RegisterActivity.kt

@@ -1,6 +1,7 @@
 package com.hyd.user.ui.activity
 
 import android.os.Bundle
+import com.hyd.base.ext.onClick
 import com.hyd.base.ui.activity.BaseMvpActivity
 import com.hyd.user.R
 import com.hyd.user.injection.component.DaggerUserComponent
@@ -12,23 +13,21 @@ import org.jetbrains.anko.toast
 
 class RegisterActivity : BaseMvpActivity<RegisterPresenter>(), RegisterView {
 
+    override fun injectComponent() {
+        DaggerUserComponent.builder().activityComponent(activityComponent).userModule(UserModule()).build().inject(this)
+        mPresenter.mView = this
+    }
+
     override fun onCreate(savedInstanceState: Bundle?) {
         super.onCreate(savedInstanceState)
         setContentView(R.layout.activity_register)
 
-        initInjection()
-
-        mRegisterBtn.setOnClickListener {
+        mRegisterBtn.onClick {
             mPresenter.register(mMobileEt.text.toString(),mVerifyCodeEt.text.toString(), mPwdEt.text.toString())
         }
     }
 
-    private fun initInjection() {
-        DaggerUserComponent.builder().activityComponent(activityComponent).userModule(UserModule()).build().inject(this)
-        mPresenter.mView = this
-    }
-
-    override fun onRegisterResult(result: Boolean) {
-        toast("注册成功")
+    override fun onRegisterResult(result: String) {
+        toast(result)
     }
 }

build.gradle

@@ -7,6 +7,8 @@ buildscript {
     ext.ok_http_version = '3.4.1'
     ext.retrofit_version = '2.4.0'
     ext.dagger_version = '2.11'
+    ext.rx_lifecycle_version = '1.0'
+
     repositories {
         google()
         jcenter()