Różnica między `share()` i `publish(). RefCount()`

Question

Jaka jest praktyczna różnica między observable.publish().refCount() i observable.share(). Co byłoby przykładem sytuacji, w której nie chcemy używać share?

Answer 1

Nie ma praktyczna różnica, jeśli spojrzeć na „observable.prototype.share” widać, że po prostu zwraca „source.publish(). RefCount()”.

Co do dlaczego nie chcesz go używać, to jest bardziej kwestia ile kontroli trzeba się gdy źródło rozpocznie nadawanie.

Po tym, jak refCount() połączy podstawową obserwowalną przy pierwszej subskrypcji, może się zdarzyć, że kolejni obserwatorzy przegapią wiadomości przychodzące, zanim będą mogły zasubskrybować.

Na przykład:

var source = Rx.Observable.range(0, 5).share(); 

var sub1 = source.subscribe(x => console.log("Observer 1: " + x)); 
var sub2 = source.subscribe(x => console.log("Observer 2: " + x)); 

Tylko pierwszy abonent otrzyma żadnych wartości, jeśli chcemy zarówno otrzymać je będziemy używać:

var source = Rx.Observable.range(0, 5).publish(); 

var sub1 = source.subscribe(x => console.log("Observer 1: " + x)); 
var sub2 = source.subscribe(x => console.log("Observer 2: " + x)); 

source.connect();