孤独プログラマー譚

孤独死が近い。

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...