0

我编写的代码是去抖动文本EditText并过滤掉少于 4 个字符的文本:

charSequenceInitialValueObservable.skipInitialValue()
    .filter(new Predicate<CharSequence>() {
      @Override public boolean test(@NonNull CharSequence charSequence) throws Exception {
        Log.d("TAG", "l: " + charSequence.length());
        return charSequence.length() > 3;
      }
    })
    .doOnNext(new Consumer<CharSequence>() {
      @Override public void accept(@NonNull CharSequence charSequence) throws Exception {
        Log.d("TAG", "1. doOnNext: \"" + charSequence + "\"");
      }
    })
    .debounce(300, TimeUnit.MILLISECONDS)
    .doOnNext(new Consumer<CharSequence>() {
      @Override public void accept(@NonNull CharSequence charSequence) throws Exception {
        Log.d("TAG", "2. doOnNext: \"" + charSequence + "\"");
      }
    })
    .subscribeWith(new DisposableObserver<CharSequence>() {
      @Override
      public void onNext(@io.reactivex.annotations.NonNull CharSequence charSequence) {
        Log.d("TAG", "onNext: \"" + charSequence + "\"");
      }

      @Override public void onError(@io.reactivex.annotations.NonNull Throwable e) {
        Log.d("TAG", "onError: " + e.toString());
      }

      @Override public void onComplete() {
        Log.d("TAG", "onComplete");
      }
    });

当用户输入文本时 - 过滤工作正常,但当用户使用退格键时,最后一个空字符序列被传递到Subscriber

1. doOnNext: "test hhu"
l: 7
1. doOnNext: "test hh"
l: 6
1. doOnNext: "test h"
l: 5
1. doOnNext: "test "
l: 4
1. doOnNext: "test"
l: 3
l: 2
l: 1
l: 0
2. doOnNext: ""
onNext: ""

这是预期的行为吗?我应该在去抖后第二次使用过滤器运算符吗?如何正确过滤掉它?

4

1 回答 1

2

Debounce 在给定超时没有传​​递任何值后通过最后一个值,所以理论上它应该通过"test". 然而,唯一通过""的值可能表明该值不是不可变的,并且在通过去抖动运算符之前被覆盖。

要解决此问题,请确保charSequenceInitialValueObservable仅接收不可变值或在debounce. (有点像.map(cs -> new String(cs))

于 2017-04-26T16:39:17.827 回答