rx binding sample

-- rx dependencis --
// RxJava + RxAndroid
implementation 'io.reactivex.rxjava2:rxandroid:2.1.1'
implementation 'io.reactivex.rxjava2:rxjava:2.2.8'

// RxBinding
implementation 'com.jakewharton.rxbinding2:rxbinding:2.2.0'


-- logic binding edit text --
-- SearchActivity.kt --

class SearchActivity : AppCompatActivity() {

    private val TAG = this::class.java.simpleName + TSMLOG
    private val searchAdapter = SearchAppAdapter()
    private val disposable = CompositeDisposable()
    private lateinit var searchViewModel: SearchViewModel


    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_search)
        ViewUtil.customStatusAndNav(this)

        val type = intent.getIntExtra("type", TYPE_APP)
        when (type) {
            TYPE_APP -> initSearchApps(resources.getColor(R.color.appsAccent))
            TYPE_GAMES -> initSearchApps(resources.getColor(R.color.gamesAccent))
        }

        list_result.layoutManager = LinearLayoutManager(this)
        list_result.addItemDecoration(DividerItemDecoration(this, OrientationHelper.VERTICAL))

        search_view.typeface =  Typeface.createFromAsset(assets, "Roboto-Regular.ttf")
        progress_circular.visibility = View.GONE

        btn_back.setOnClickListener {
            super.onBackPressed()
        }
    }

    private fun initSearchApps(color: Int) {
        list_result.adapter = searchAdapter
        search_view.imeOptions = EditorInfo.IME_ACTION_SEARCH
        search_view.requestFocus()


        appbar_main.setBackgroundColor(color)
        disposable.add(
                RxTextView.textChanges(search_view)
                        .subscribeOn(Schedulers.io())
                        .observeOn(Schedulers.computation())
                        .filter { it.length > 1 }
                        .map { it.toString() }
                        .debounce(500, TimeUnit.MILLISECONDS)
                        .observeOn(AndroidSchedulers.mainThread())
                        .subscribe({ query ->
                            searchViewModel = ViewModelProviders.of(this).get(SearchViewModel::class.java)
                            searchViewModel.getApps(query).observe(this, Observer {
                                progress_circular.visibility = View.VISIBLE
                                searchAdapter.submitList(it)
                            })

                            searchViewModel.getLoader().observe(this, Observer {
                                progressConfig(progress_circular, it)
                            })

                        }, { e ->
                            Log.i(TAG, e.message)
                        })
        )
    }

    override fun onDestroy() {
        super.onDestroy()
        disposable.dispose()
    }
}