rxjava中debounce()操作员的意外行为

Question

我正在使用 RxBinding来验证表单输入。

问题是当我尝试使用debounce()运算符(如应用程序不当行为(时，它不会崩溃，但是在我打开调用setupForm() 的活动之后，该应用程序会重新启动，而不会显示任何崩溃的迹象。

当我删除debounce()时，它可以很好地工作。

这是我的代码。

 private void setupForm() {
    Observable<Boolean> itemNameObservable = RxTextView.textChanges(tilItemName.getEditText()).
            map(text -> (text.toString().length() > 6))
            .distinctUntilChanged();
    itemNameObservable.subscribe(valid -> {
        tilItemName.setError(getString(R.string.error_invalid_itemNam));
        tilItemName.setErrorEnabled(!valid);
    });

    Observable<Boolean> descObservable = RxTextView.textChanges(tilItemDescription.getEditText()).
            map(text -> (text.toString().length() > 6))
            .debounce(500, TimeUnit.MILLISECONDS)
            .distinctUntilChanged();
    descObservable.subscribe(valid -> {
        tilItemDescription.setError(getString(R.string.error_invalid_description));
        tilItemDescription.setErrorEnabled(!valid);
    });

    Observable<Boolean> cityObservable = RxTextView.textChanges(tilFinderCity.getEditText()).
            map(text -> (text.toString().length() > 6))
            .debounce(500, TimeUnit.MILLISECONDS)
            .distinctUntilChanged();
    cityObservable.subscribe(valid -> {
        tilFinderCity.setError(getString(R.string.error_invalid_city));
        tilFinderCity.setErrorEnabled(!valid);
    });

    Observable<Boolean> phoneObservable = RxTextView.textChanges(tilFinderPhone.getEditText()).
            map(text -> (text.toString().length() > 6))
            .debounce(500, TimeUnit.MILLISECONDS)
            .distinctUntilChanged();
    phoneObservable.subscribe(valid -> {
        tilFinderPhone.setError(getString(R.string.error_invalid_phone));
        tilFinderPhone.setErrorEnabled(!valid);
    });

    //combine all value from inputs and (&&) them. add button is enabled if all are set
    Observable.combineLatest(
            itemNameObservable
            , descObservable
            , cityObservable,
            phoneObservable
            , (itemNameIsValid, descIsValid, cityIsValid, phoneIsValid) -> (cityIsValid && descIsValid && phoneIsValid && itemNameIsValid))
            .distinctUntilChanged()
            .subscribe(shouldEnable -> btnAddItem.setEnabled(shouldEnable));

    RxView.clicks(btnAddItem)
            .subscribe(view -> presnter.addItem(getItemFromForm()));

}

Answer 1

debounce操作员默认在computation调度程序上操作，这就是您的应用程序崩溃的原因。您可以通过查看日志来验证这一点，您会看到类似android.view.ViewRootImpl$CalledFromWrongThreadException: Only the original thread that created a view hierarchy can touch its views.

的东西

解决方案是在debounce()调用后立即添加此行.observeOn(AndroidSchedulers.mainThread())。

Answer 2

使用rxtextview.textchanges时，请记住，在订阅期间，它会立即发出结果，因此您必须考虑到这一点。它不能影响您的代码，或者您可以执行.skip(1(

之类的事情

我认为，在审问时，您也应该包括一个背压策略，因此请尝试以下内容：

Observable<Boolean> phoneObservable = 
RxTextView.textChanges(tilFinderPhone.getEditText())
            .map(text -> (text.toString().length() > 6))
            .debounce(500, TimeUnit.MILLISECONDS)
            .toFlowable(BackpressureStrategy.LATEST)
            .distinctUntilChanged();

将要：

/**
 * Keeps only the latest onNext value, overwriting any previous value if the
 * downstream can't keep up.
 */