前置き

cold/hot observable について、気になったあれこれを調べて動作確認をしたのでそのメモ。
確認方法としては、下記ページを作成し、console.log の出力を見て確認した。

本編

cold observable

Subscription とストリームが1対1の関係。
そのため、Observable を都度生成しても使いまわしてもSubscriber の挙動は同じ。
ストリームがcomplete または、Subscription がunsubscribe すると両者破棄される。

hot observable

Subscription とストリームが多対1となりうる関係。
そのため、Observable を
都度生成すると、1対1となるため複数のSubscriber が異なる挙動をする。(cold と同じ)
使いまわすと、多対1となるため複数のSubscriber が同じ挙動をする。

また、ストリームがcomplete すると、ストリームとそれに紐づくSubscription の両者破棄される。(cold と同じ)
しかし、あるストリームに紐づくSubscription すべてがunsubscribe すると、ストリームも破棄される場合とされない場合がある。

Angular でshareReplay を使うにあたって

shareReplay(1) は紐づくSubscription すべてがunsubscribe してもストリームが破棄されない。
つまり、Async Pipe を使用していてもストリームが破棄されない。
そういう時はshareReplay({ bufferSize: 1, refCount: true }) を使用すれば、すべてがunsubscribe されたときにストリームも破棄される。
または、takeUntilDestroyed を使用すればcomplete してくれるので問題ない。

感想

楽しかった。
あと、hot の挙動が直感と違って戸惑った。

今回の記事は以上です。

前回記事はこちら

詳細見たい人はこちら