RxAndroid 重新订阅 Observable onError 和 onComplete

Question

我的问题可能更多是概念性的。
我通过Observable 合同得知，在调用onComplete 或onError 之后，我的Observable 将不再发出任何项目。
但我使用的是 Android 的 RxBindings，因此它不是“我的Observable”，而是点击发出项目的Button。

fun observeForgotPasswordButton(): Disposable {
    return view.observeForgotPasswordButton()
            .flatMap {
                authService.forgotPassword(email).toObservable<Any>()
            }
            .subscribe({
                // on next
                Timber.d("fun: onNext:")
            }, { error ->
                // on error
                Timber.e(error, "fun: onError")
            }, {
                // onComplete
                Timber.d("fun: onComplete")
            })
}

observeForgotPasswordButton() 返回一个Observable

fun observeForgotPasswordButton(): Observable<Any> = RxView.clicks(b_forgot_password)

问题是authService.forgotPassword(email) 是Completable，它会调用onComplete 或onError，这两者都导致我无法再重复使用该按钮，因为订阅结束了。
有没有办法规避这种行为？ 因为在发生错误时我希望能够重试。
此外，我希望可以发送多个忘记密码的电子邮件。

Answer 1

您可以使用retry() 和repeat() 运算符自动重新订阅原始Observable（或Completable）。

fun observeForgotPasswordButton(): Disposable {
    return view.observeForgotPasswordButton()
            .flatMap {
                authService.forgotPassword(email).toObservable<Any>()
            }
            .repeat() // automatically resubscribe on completion
            .retry()  // automatically resubscribe on error
            .subscribe({
                // on next
                Timber.d("fun: onNext:")
            }, { error ->
                // on error
                Timber.e(error, "fun: onError")
            }, {
                // onComplete
                Timber.d("fun: onComplete")
            })
}