使用 RxJava 进行电子邮件登录验证，可观察对象发出两次

我正在制作一个简单的登录表单（电子邮件和密码）来尝试增强我的反应式编程技能。我在让电子邮件字段验证按照我想要的方式工作时遇到一些问题。

这是我的代码：

    final Observable<CharSequence> email = RxTextView.textChanges(emailView);

    Observable<Boolean> emailIsValid = email.map(new Func1<CharSequence, Boolean>() {
        @Override
        public Boolean call(CharSequence charSequence) {
            Log.d("asdf", "emailIsValid call: " + charSequence);
            return Pattern.matches(Patterns.EMAIL_ADDRESS.pattern(), charSequence);
        }
    });
    RxView.focusChanges(emailView)
            .withLatestFrom(emailIsValid, new Func2<Boolean, Boolean, Boolean>() {
                @Override
                public Boolean call(Boolean hasFocus, Boolean emailIsValid) {
                    return (!hasFocus && !emailIsValid);
                }
            })
            .subscribe(new Action1<Boolean>() {
                @Override
                public void call(Boolean showError) {
                    if (showError) {
                        emailInputLayout.setError("Enter a valid email");
                    } else {
                        emailInputLayout.setError(null);
                    }
                }
            });
    Observable<CharSequence> password = RxTextView.textChanges(passwordView);

    Observable.combineLatest(emailIsValid, password,
            new Func2<Boolean, CharSequence, Boolean>() {
                @Override
                public Boolean call(Boolean emailIsValid, CharSequence password) {
                    Log.d("asdf", "valid: " + emailIsValid + ", password: " + password);
                    return (emailIsValid && password.length() > 0);
                }
            })
            .subscribe(RxView.enabled(loginButton));

这是日志：

emailIsValid call: emailIsValid call: valid: false, password: // I type 'j' emailIsValid call: j emailIsValid call: j valid: false, password: // I type 'a' emailIsValid call: ja emailIsValid call: ja valid: false, password:

如你看到的，emailIsValid每次我键入一个字符时都会调用两次，这意味着它会执行两次正则表达式匹配，这有点浪费。

我查了一下如何制作emailIsValid每次更改只调用一次，无论有多少订阅者，我发现share()方法。这是我添加时发生的情况.share()到最后emailIsValid的声明：

emailIsValid call: // I type 'j' emailIsValid call: j valid: false, password: // I type 'a' emailIsValid call: ja valid: false, password:

这解决了问题，但它导致了另一个问题：没有初始发射emailIsValid to the combineLatest函数位于最后，因此登录按钮开始启用，而实际上它应该被禁用（变灰）。

解决这个问题最干净的方法是什么？我think我希望它表现得像BehaviorSubject，但我不确定这是否是最好的方法。

I think这里发生的事情如下：

• 首先subscribe- 末尾的那个RxView.focusChange()...- 导致订阅emailIsValid（因此也为了email).

• email然后将立即发出当前内容TextView作为其第一项，依次经过emailIsValid and share然后到第一个Subscriber（即withLatestFrom操作员）。

• 一段时间后combineLatest导致另一个订阅emailIsValid. Since emailIsValid is shared、此订阅不会“通过”email因此每个项目仍然只会被发射一次。

• 现在的问题是share行为就像PublishSubject: 就是发出来的任何未来向所有订阅者发送事件，但它不会重播任何过去的事件。

总而言之，这意味着：当第二个Subscriber (the combineLatest) 到达时，初始值已经过去 - 它是在第一次订阅后立即发出的。并且只有当你change的内容TextView.

解决方案： Try replay(1).refCount()代替share()在......的最后emailIsValid- 这应该确保每个新的订阅者也收到最近的评估结果以及所有未来的评估结果。

我希望这能解决问题并且我的解释有意义。