RxJs - 約束の同じ結果を待っている複数の加入者

Question

新しい決議を与えられた後任者が既に機内にいる場合、同じ約束を待っている複数の加入者を解決するにはどうすればよいですか？

doSomething =() => { 
    return new Promise((resolve) => { 
    setTimeout(() => resolve(Math.random(), 1000) 
    }) 
} 

// how to define obs? 

obs.subscribe(v => console.log(v)); // 0.39458743297857473 
obs.subscribe(v => console.log(v)); // 0.39458743297857473 
obs.subscribe(v => console.log(v)); // 0.39458743297857473 

setTimeout(() => obs.subscribe(v => console.log(v)), 2000); // 0.9485769395265746 

私は、観察結果は、後続のすべての同時加入者にストリーミングされた後、再び冷たい行き、その後、第1の加入者まで冷たいままにしたいと思います。私は基本的に同じ基本的な機能への同時リクエストを望んでいません。

Answer 1

あなたは、ストリームの作成、オペレーターとしてdeferを使用して、shareことができます。ドキュメントへのリンクはいいだろうが、

doSomething =() => { 
    return new Promise((resolve) => { 
    setTimeout(() => resolve(Math.random(), 1000)); 
    }); 
} 

const obs = Rx.Observable 
    .defer(doSomething) 
    .share(); 

obs.subscribe(console.log); // resolve #1 
obs.subscribe(console.log); // resolve #1 
obs.subscribe(console.log); // resolve #1 

setTimeout(() => obs.subscribe(console.log), 2000); // resolve #2 

<script src="https://unpkg.com/rxjs/bundles/Rx.min.js"></script>