RxJavaボタンが押されたときに繰り返されるイベントを生成するために観測可能

Question

私は、ユーザがビューを押し続けている間に繰り返しイベントを生成するオブザーバブルを作成しようとしています。下のコードはうまく動作しますが、初めての場合（ユーザーがボタンをもう一度押すと、何も起こりません）。私は間違って何をしているのかアドバイスしてもらえますか？これには何がベストプラクティスですか？

val touches = RxView.touches(previousButton) 
touches 
     .filter({ event -> event.action == MotionEvent.ACTION_DOWN }) 
     .flatMap({ 
      Observable.interval(500, 50, TimeUnit.MILLISECONDS) 
        .takeUntil(touches.filter({event -> event.action == MotionEvent.ACTION_UP})) 
     }).subscribe({ println("down") }) 

Answer 1

問題は、1つ以上のソースについて観察可能なRxView.touchesが存在しないことです。これは、flatMapのサブスクリプションが発生したときに、flatMapをトリガするために使用された元のサブスクリプションを破棄し、再度発生しないことを意味します。

1. 使用.publish(...)ではなくtouchesを使用してのイベントのソースを共有する：

   この周りの2つの方法があります。

2. イベントをオン/オフ観測可能にBooleanにマッピングし、次にswitchMapにオブザーバブルの現在の値に基づいて適切なアクションを割り当てます。

1.

touches.publish { src -> 
    src.filter(...) 
     .flatMap { 
      Observable.interval(...) 
        .takeUntil(src.filter(...)) 
     } 
} 

2.

touches.filter { 
      it.action == MotionEvent.ACTION_DOWN 
       or it.action == MotionEvent.ACTION_UP 
     } 
     .map { it.action == MotionEvent.ACTION_DOWN } 
     .distinctUntilChanged() // Avoid repeating events 
     .switchMap { state -> 
      if (state) { 
       Observable.interval(...) 
      } else { 
       Observable.never() 
      } 
     }