Debounced Text Watcher

Extensions.kt

@ExperimentalCoroutinesApi
fun EditText.doAfterTextChanged(): Flow<CharSequence?> {
    return callbackFlow<CharSequence?> {
        val listener = object : TextWatcher {
            override fun beforeTextChanged(s: CharSequence?, start: Int, count: Int, after: Int) =
                Unit

            override fun onTextChanged(s: CharSequence?, start: Int, before: Int, count: Int) = Unit
            override fun afterTextChanged(s: Editable?) {
                offer(s)
            }
        }
        addTextChangedListener(listener)
        awaitClose { removeTextChangedListener(listener) }
    }.onStart { emit(text) }
}

Usage:

searchEditText.doAfterTextChanged()
                .distinctUntilChanged()
                .debounce(300)
                .onEach { //Do search Here }
                .launchIn(lifecycleScope)