思考 - 用响应式思路来处理输入框

写本文的初衷

为啥会有这篇呢，由于我看到了一篇使用 kotlin 扩展函数来作输入框处理的文章，看文以后那小代码的确简洁，可是以后我就先入自我思考了，咱们写代码的第一要务是什么，就是为了尽量的代码少吗，为了这个其余都无论啦？

你们先看我看到的例子：

• 来源： Kotlin扩展函数与高阶函数-实际应用
• 目的： 使用 koltin 扩展函数来简化代码
• 场景： 在多个输入框的条件下，只有全部输入框都正确输入内容了，底部的注册按钮才能使用
• 追求： 代码简洁
• 图：

  

• 扩展函数代码： method 函数是用来注册按钮是否可使用

fun Button.enable(et: EditText, method: () -> Boolean){
    val btn = this
    et.addTextChangedListener(object : TextWatcher{
        override fun afterTextChanged(s: Editable?) {
        }

        override fun beforeTextChanged(s: CharSequence?, start: Int, count: Int, after: Int) {
        }

        override fun onTextChanged(s: CharSequence?, start: Int, before: Int, count: Int) {
            btn.isEnabled = method()
        }
    })
}
复制代码

• 上面传递进来的 method 函数：

private fun isBtnEnable():Boolean{
        return mMobileEt.text.isNotEmpty() &&
                mVerifyCodeEt.text.isNotEmpty() &&
                mPwdEt.text.isNotEmpty()&&
                mConfirmPwdEt.text.isNotEmpty()
    }
复制代码

• 使用：

mRegisterBtn.enable(mMobileEt,{isBtnEnable()})
    mRegisterBtn.enable(mVerifyCodeEt,{isBtnEnable()})
    mRegisterBtn.enable(mPwdEt,{isBtnEnable()})
    mRegisterBtn.enable(mConfirmPwdEt,{isBtnEnable()})
复制代码

代码看完了，你们感受下，这样写有什么感受。个人感受是这样干只是为了代码简洁一点，可是其思路自己混乱了代码设计，将代码置于何其不想干的地方。代码虽然少了，可是变得不容易理解了，得不偿失，不是个人追求

---

代码设计的目标

这里说说我本身对代码设计的追求：

• 逻辑完成性 代码的逻辑性必须保持，这是第一位的要务，必须遵照你们约定俗成的写法、思路、命名，不容易理解的代码写的再好也是不合格的，代码是看的，我宁愿写的时候麻烦一些，代码多一些，也得保证之后能快速看懂，快速定位代码位置
• 功能分层 在保证逻辑性的前提下，从完成的逻辑流程中，把逻辑拆分红一段一段互不相干的，互不涉及的功能，而后把他们按照设计思路整理下

基本上就是这点，我这 coder 水平也是 菜的一B，你们见谅吧

---

Reactive 改造思路

我是不喜欢上面的那种写法，我决定使用 Reactive 响应式的思路来写我心里中的代码：

• 一切都是事件，输入自己也是一个事件，输入框自己只要校验数据，发射事件就好了
• 把 if/else 判断输入框是否是都有内容的逻辑判断尽可能按照 表驱动法 的思路改造一下，使用 map 来承接输入内容
• 监听输入事件，进行逻辑处理，要不要让注册按钮可用
• 这里使用 Rxjava2 的 PublishSubject 热发射 来构建输入事件流

效果图：

---

代码

我就再也不拆开了解释了，代码挺简单的，你们撸着看就好了

package com.bloodcrown.bw.rearctive

import android.os.Bundle
import android.support.v7.app.AppCompatActivity
import android.text.Editable
import android.text.TextWatcher
import android.widget.Toast
import com.bloodcrown.bw.R
import io.reactivex.subjects.PublishSubject
import kotlinx.android.synthetic.main.activity_reactive_input.*

class ReactiveInputActivity : AppCompatActivity() {

    // 表驱动法：输入数据表
    var inputTable = mutableMapOf(
            InputType.phone to "",
            InputType.verify to "",
            InputType.password1 to "",
            InputType.password2 to ""
    )
    
    // 输入事件流
    var inputSubject: PublishSubject<InputMessage> = PublishSubject.create()

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_reactive_input)

        // 初始化输入框监听
        initTextWatcher()
        // 注册输入事件监听
        subscribeInput()

        btn_regist.setOnClickListener {
            Toast.makeText(this@ReactiveInputActivity, "注册成功", Toast.LENGTH_SHORT).show()
        }

    }

    /** * 注册输入框监听函数，内部只管发射数据，无论其余路逻辑处理 */
    fun initTextWatcher() {
        edit_phone.addTextChangedListener(object : TextWatcher {
            override fun afterTextChanged(s: Editable?) {
            }

            override fun beforeTextChanged(s: CharSequence?, start: Int, count: Int, after: Int) {
            }

            override fun onTextChanged(s: CharSequence?, start: Int, before: Int, count: Int) {
                inputSubject.onNext(InputMessage(InputType.phone, s.toString()))
            }
        })

        edit_verify.addTextChangedListener(object : TextWatcher {
            override fun afterTextChanged(s: Editable?) {
            }

            override fun beforeTextChanged(s: CharSequence?, start: Int, count: Int, after: Int) {
            }

            override fun onTextChanged(s: CharSequence?, start: Int, before: Int, count: Int) {
                inputSubject.onNext(InputMessage(InputType.verify, s.toString()))
            }
        })

        edit_password_1.addTextChangedListener(object : TextWatcher {
            override fun afterTextChanged(s: Editable?) {
            }

            override fun beforeTextChanged(s: CharSequence?, start: Int, count: Int, after: Int) {
            }

            override fun onTextChanged(s: CharSequence?, start: Int, before: Int, count: Int) {
                inputSubject.onNext(InputMessage(InputType.password1, s.toString()))
            }
        })

        edit_password_2.addTextChangedListener(object : TextWatcher {
            override fun afterTextChanged(s: Editable?) {
            }

            override fun beforeTextChanged(s: CharSequence?, start: Int, count: Int, after: Int) {
            }

            override fun onTextChanged(s: CharSequence?, start: Int, before: Int, count: Int) {
                inputSubject.onNext(InputMessage(InputType.password2, s.toString()))
            }
        })
    }

    /** * 监听输入事件流，进行逻辑处理 */
    fun subscribeInput() {
        inputSubject.subscribe {
            // 同步数据到输入表中
            inputTable[it.inputTupe] = it.value
            // 判断按钮是否可用
            if (isCanRegist()) btn_regist.isEnabled = true else btn_regist.isEnabled = false
        }

    }

    /** * 安妮是否可用，这里表驱动法并无减小代码，反而增长了不是代码 * 可是这样看我以为逻辑清洗多了，也不用再单独管理输入数据了 */
    fun isCanRegist(): Boolean {
        var result = true
        for ((k, v) in inputTable) {
            if (v.isEmpty()) return false
        }
        return result
    }
}

/** * 输入类型 */
enum class InputType {
    phone, verify, password1, password2
}

/** * 输入数据对象 */
data class InputMessage(var inputTupe: InputType, var value: String)


复制代码