熱く観測できるのはいつ最初の値を出しますか？

Question

私はこのペンを作成します。 http://codepen.io/hatelove85911/pen/Vjmwwb

const Ob = Rx.Observable 
const button = document.querySelector('#click') 

const count$ = Ob.fromEvent(button, 'click') 
       .scan(acc=>++acc,0) 
       .share() 
setTimeout(()=>{ 
    count$.subscribe(x=>console.log('sub1:',x)) 
},5000) 

setTimeout(()=>{ 
    count$.subscribe(x=>console.log('sub2:',x)) 
},10000) 

すべてのオンラインの記事には、加入者がありません場合でも、ホット、観察開始が値を発することを言います。

この例では、私はそれを熱くするために観測値を共有しました。 最初のサブスクライバの前に1より大きい累積値を得ることを期待して、ボタンを数回クリックし続けますが、最初のサブスクライバが来ると、そのログは1から開始しますが、2番目のサブスクライバのログは中間から開始します、1からではありません。

誰かがこれがなぜ起こっているのか説明できますか？

Answer 1

ホット/温かい/冷たい用語は常に混乱になるだろう。私はフードの中で何が起きているのかを正確に理解するために気温の比喩を逃れようとします。

基本的に、すべての（Rxjs）観測値（を除いて）は怠惰です。つまり、加入者がいない場合（オブザーバーとも呼ばれる）、データフロー（または実際には何もない）が存在しないことを意味します。サブスクリプションで発生したサブスクリプションとデータフローの詳細な説明がここにあります：Hot and Cold observables : are there 'hot' and 'cold' operators?

shareは観測可能であり、観測可能でもありません。したがって、プロデューサー（あなたのオペレーター連鎖によって明らかにされる）は最初のサブスクリプションではじめて開始されます。したがって、サブスクリプションの前にクリックしても、何も実行されません。一度購読すると、プロデューサーが実行され、オブザーバー/サブスクリプションは値1を生成します。

あなたがリンクされ図示されたデータフローで見ることができるように、shareはそうOb.fromEvent(button, 'click').scan(acc=>++acc,0)がそれに加入主題を持っているpublishがmulticast(new Rx.Subject())あるpublish().refCount()の別名です。ここで重要なのは、サブジェクトが実際にはサブスクリプションされていないことですが、connect()にコールするときにはサブジェクトになります。被験者が購読したら、値がに到達した時点で、それが登録された観察者に受信した値をすべてに渡します。それは、ホットな行動であると考えられる行動です。混乱する部分は、熱い観察可能なものが観察可能であり、それゆえにまだ怠け者であることです（怠け者ではないものを除いて）。

詳細については、publishは接続可能な観測可能（まだレイジー）を返します。あなたがそれを購読するとき、あなたは上記の主題に加入しています。しかし、あなたがconnect()をしていない限り、そのサブジェクトはそれ自体が観測可能なソースに登録されていません。したがって、データは流れません。

であなたのcodepenを置き換え、これをあなたに納得させる：だからobs.publish(); obs.subscribe(observer1)で短期的に、あなたが接続する前a-->bはb is subscribed to aを意味し、次の状態obs | subject -> observer1を持って

const Ob = Rx.Observable 
const button = document.querySelector('#click') 

const count$ = Ob.fromEvent(button, 'click') 
       .scan(acc=>++acc,0) 
       .publish(); 
setTimeout(()=>{ 
    count$.subscribe(x=>console.log('sub1:',x)) 
},1000) 


setTimeout(()=>{ 
    count$.subscribe(x=>console.log('sub2:',x)) 
    count$.connect(); 
},5000) 

。サブジェクトは受信した値だけを渡し、受信していないため、どのソースにもサブスクライブしていないため、データは流れません。

connect()の場合は、状態はobs -> subject -> observer1です。したがって、obsプロデューサーが開始し、その値を受け取った瞬間に観測者に値を送信するサブジェクトに値を送信します。

Answer 2

私はRxJSも新しくなっていますが、fromEventは「暖かい」Observableのような感じです。基本的には、実際のサブスクリプションが発生するまでは追跡が始まらないという点で怠惰です。 shareは一度購読してしまえば暑いですが、その怠惰のために最初の購読までは何も追跡されないので、それはまだその意味で "暖かい" Observableです。

最初のサブスクリプションの前にクリックが追跡され、.publish()（ConnectableObservablesを返す）を使用してからすぐに.connect()を使用することができます。

Codepen.io Example

const Ob = Rx.Observable 
const button = document.querySelector('#click') 

const count$ = Ob.fromEvent(button, 'click') 
       .scan(acc=>++acc,0) 
       .publish(); // <-- publish here 

count$.connect(); // <--immediately connect to it 

setTimeout(()=>{ 
    count$.subscribe(x=>console.log('sub1:',x)) 
},5000) 


setTimeout(()=>{ 
    count$.subscribe(x=>console.log('sub2:',x)) 
},10000)