孤独プログラマー譚

孤独死が近い。

2020-04-08から1日間の記事一覧

RxJS exhaustMap

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

RxJS オペレータscan, reduceの違い

scanはストリームごとにnextを発火する。 of(1, 2, 3, 4).pipe( scan((acc, val) => acc + val, 10) ) .subscribe(cl) // 11, 13, 16, 20 reduceは、最後のストリームだけ、nextを発火する。 of(1, 2, 3, 4).pipe( reduce((acc, val) => acc + val, 100) ) .…