RxJs - Mehrere Abonnenten warten auf das gleiche Ergebnis eines Versprechens

Question

Wie bekomme ich mehrere Abonnenten warten das gleiche Versprechen zu lösen, wenn es bereits bei Nachzügler angesichts einer neuen Auflösung inflight ist?

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 

Ich möchte die beobachtbaren, bis der erste Teilnehmer kalt bleiben, dann kalt gehen wieder nach dem Ergebnis für alle nachfolgenden gleichzeitige Teilnehmer gestreamt wird. Ich möchte im Grunde keine gleichzeitige Anfragen an die gleiche zugrunde liegende Funktion.

Answer 1

Sie defer als creation-Operator verwenden und dann share der Strom:

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>