如何在MultiAutoCompleteTextView中使用rxjava2？

implementation 'io.reactivex.rxjava2:rxjava:2.x.x'
implementation 'io.reactivex.rxjava2:rxandroid:2.x.x'

MultiAutoCompleteTextView multiAutoCompleteTextView = findViewById(R.id.multiAutoCompleteTextView);
ArrayAdapter<String> adapter = new ArrayAdapter<>(this, android.R.layout.simple_dropdown_item_1line, data);
multiAutoCompleteTextView.setAdapter(adapter);

Observable<CharSequence> textChangeObservable = RxTextView.textChanges(multiAutoCompleteTextView)
        .debounce(300, TimeUnit.MILLISECONDS) // 设置一个延迟时间，避免频繁触发事件
        .subscribeOn(AndroidSchedulers.mainThread()) // 在主线程中执行
        .observeOn(Schedulers.io()); // 在IO线程中执行

textChangeObservable
        .flatMap(new Function<CharSequence, ObservableSource<List<String>>>() {
            @Override
            public ObservableSource<List<String>> apply(CharSequence charSequence) throws Exception {
                // 执行网络请求或其他耗时操作，并返回结果
                List<String> result = performSearch(charSequence.toString());
                return Observable.just(result);
            }
        })
        .observeOn(AndroidSchedulers.mainThread()) // 切换回主线程
        .subscribe(new Consumer<List<String>>() {
            @Override
            public void accept(List<String> result) throws Exception {
                // 处理结果并更新UI
                adapter.clear();
                adapter.addAll(result);
                adapter.notifyDataSetChanged();
            }
        });