Die zweite Subskription für eine gemeinsame Zuordnung von BehaviorSubject wird nicht ausgeführt.

Question

Wenn ich eine gemeinsame Zuordnung von BehaviorSubject instance (t) abonniere, wird nur die erste Subskription ausgeführt.

Wenn das Original BehaviorSubject (obj) einen zweiten Wert ausgibt, wird nur der letzte Wert gedruckt, und beide Abonnements wurden ausgeführt.

mein Code

const obj = new Rx.BehaviorSubject(1) 
obj.subscribe(console.log) 
const t = obj.map(u => { 
    console.log("mapped") 
    return u * 10 
}).share() 

t.subscribe(x => console.log("subscribe 1 " + x)) 
t.subscribe(x => console.log("subscribe 2 " + x)) 
//with the following line un-commented, both subscriptions print out new value 
//obj.next(2) 

Mein erwartetes Ergebnis ist

1 
mapped 
subscribe 1 10 
subscribe 2 10 

aber das tatsächliche Ergebnis war

1 
mapped 
subscribe 1 10 

Sorry für die naive Frage Let überprüfen. Kann mir das jemand erklären?

Vielen Dank

Answer 1

In Ihrem Beispiel:

• die BehaviorSubject in obj.

• Subject Instanz innerhalb .share().

Denken Sie daran, dass BehaviorSubject seinen zwischengespeicherten Wert emittiert nur, wenn Sie es abonnieren.

Der erste Beobachter obj.subscribe(console.log) abonniert direkt die BehaviorSubject. Dies druckt 1.

Dann erstellen Sie eine Kette t, die mit dem Operator share() endet.

Jetzt abonnieren Sie t mit t.subscribe. Dies bedeutet, dass Sie die Subject innerhalb share() abonnieren, und da dies der erste Beobachter ist, muss er die Quelle Observable abonnieren (die wiederum die Quelle BehaviorSubject erreicht, die ihren zwischengespeicherten Wert ausgibt). Beachten Sie, dass share() nur eine Abkürzung für die Verwendung des Operators multicast() mit refCount() ist.

Und die letzte Zeile, die Sie erneut abonnieren mit t.subscribe. Genau wie zuvor abonniert dies die Subject innerhalb share(). Allerdings ist share() bereits auf seine Quelle Observable abonniert, so dass es nicht ein weiteres Abonnement macht. Das ist der Punkt des Multicasting und der Operator multicast().

Deshalb werden Sie keine subscribe 2 10 sehen, und Sie werden kein Ereignis siehe mapped zweimal gedruckt. Sie abonnieren die Subject innerhalb share(), nicht die Quelle BehaviorSubject.

Answer 2

Jeder Unternehmer (einschließlich der share) tatsächlich schafft einen neuen Sub-Observable, die seine eigene Anteil/Wiedergabe-Eigenschaften hat, die von der Quelle beobachtbare abgelöst werden.

Um Ihr Ergebnis zu erhalten, sollten Sie publishReplay(1) statt share() verwenden. (Mit publishReplay Sie haben natürlich entweder refCount() oder connect() zu verwenden) Sie haben zwei Themen

const obj = new Rx.BehaviorSubject(1) 
 
obj.subscribe(console.log) 
 
const t = obj.map(u => { 
 
    console.log("mapped") 
 
    return u * 10 
 
}).publishReplay(1) 
 
.refCount(); 
 

 
t.subscribe(x => console.log("subscribe 1 " + x)) 
 
t.subscribe(x => console.log("subscribe 2 " + x)) 
 
//with the following line un-commented, both subscriptions print out new value 
 
//obj.next(2)

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