在 RxJava2 中创建去抖动器

Question

在 RxJava1 中，您可以通过这种方式创建去抖动器

RxSearchView.queryTextChanges(searchView)
    .debounce(1, TimeUnit.SECONDS) // stream will go down after 1 second inactivity of user
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new Consumer<CharSequence>() {
        @Override
        public void accept(@NonNull CharSequence charSequence) throws Exception {
            // perform necessary operation with `charSequence`
        }
    });

根据Wait until the user stops typing before executing a heavy search in searchview

但我不知道如何在 RxJava2 中创建它

Answer 1

删除

import io.reactivex.functions.Consumer;

添加

import java.util.function.Consumer;

RxSearchView.queryTextChanges(searchView)
    .debounce(1, TimeUnit.SECONDS) // stream will go down after 1 second inactivity of user
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(result -> new Consumer<CharSequence>() {
                @Override
                public void accept(CharSequence charSequence) {
                    // use result
                }
            });