使用RxJava Android实现TextWatcher

EditText editText = findViewById(R.id.editText);

Observable<String> textChangeObservable = Observable.create(emitter -> {
    TextWatcher textWatcher = new TextWatcher() {
        @Override
        public void beforeTextChanged(CharSequence s, int start, int count, int after) {
            // 在文本变化之前执行的操作
        }

        @Override
        public void onTextChanged(CharSequence s, int start, int before, int count) {
            // 在文本变化过程中执行的操作
            emitter.onNext(s.toString()); // 发射文本变化的内容
        }

        @Override
        public void afterTextChanged(Editable s) {
            // 在文本变化之后执行的操作
        }
    };

    editText.addTextChangedListener(textWatcher);

    // 在Observable被订阅时移除TextWatcher
    emitter.setCancellable(() -> editText.removeTextChangedListener(textWatcher));
});

textChangeObservable
    .debounce(300, TimeUnit.MILLISECONDS) // 设置一个延迟时间，避免频繁触发事件
    .observeOn(AndroidSchedulers.mainThread()) // 在主线程中观察事件
    .subscribe(text -> {
        // 处理文本变化事件
    });