RxBindings を使用した Rx チェーンの例を次に示します。
RxView.clicks(refreshIcon)
.flatMap { Observable.error<Throwable>(IllegalArgumentException()) }
.subscribe(
{ Timber.d("onNext")},
{ error -> Timber.d("onError") })
.addTo(disposables)
更新アイコンを 1 回クリックすると、ターミナル イベントが発生したため、このチェーンは再度実行されません。クリック イベントが検出されるたびにサブスクリプションが行われ、実際にはそのコード ブロックが実行されるたびにサブスクリプションが行われるという間違った印象を持っていたと思います。
質問は、ターミナル イベントにヒットした後でも、クリックするたびにチェーンを実行/再実行するにはどうすればよいですか? 直感的なものを探しています。