RxJS exhaustMap
初めのストリームが優先して実行される。
実行中に後から来たストリームは、キャンセルされる。
switchMapと逆バージョンのようなイメージ。
of(0, 1, 2).pipe( exhaustMap(x => sto(x + 1)) ).subscribe(cl) // 1 timer(0, 500).pipe( exhaustMap(x => sto(x, 1000)) ).subscribe(cl) // 0,2,4,6... timer(0, 1000).pipe( exhaustMap(x => sto(x, 1000)) ).subscribe(cl) // 0,1,2,3...