rxjs：値が発行されるたびにサブスクライブします

Question

マウスをクリックするたびにmousemoveイベントを購読し、マウスをクリックするたびに購読を解除します。

// start when mousedown 
Observable.fromEvent(element, 'mousedown') 
      .subscribe(() => { 
       Observable.fromEvent(element, 'mousemove') 
         // finish when mouseup 
         .takeUntil(Observable.fromEvent(element, 'mouseup')) 
         .subscribe(() => {/*do something on mousemove*/}); 
      }); 

コードを最適化することはできますか？（「購読」方式を1つにする）

Answer 1

Observable.fromEvent(element, 'mousedown') 
    .switchMap(() => 
     Observable.fromEvent(element, 'mousemove') 
      .takeUntil(Observable.fromEvent(element, 'mouseup')) 
    ) 
    .subscribe(() => {/*do something on mousemove*/});