RxJS abbestellen mit ID

Question

Nach dem Abbestellen muss ich eine Funktion mit einer ID aufrufen, die ursprünglich in den Daten gesendet wurde. Was ist der richtige Weg?

Es ist eine verschachtelte Observable wie im folgenden Ausschnitt zu sehen.

Observable.create(subscriber => { 
    const myData = nested.getData 
     .map(x => x > 1) 
     .subscribe(subscriber); 

    return() => { 
     myData.unsubscribe(); 
     callWithIdThatIsInData({id:123}) 
    }; 
}) 

Wenn unsubscribed, ich callWithIdThatIsInData müssen() mit einer Eigenschaft, was beobachtbar in der verschachtelten gesendet wurde ..

Kann jemand mich in die richtige Richtung zeigen, bitte?

Answer 1

Eine Lösung besteht darin, Ihre Eigenschaften, die mit Ihrer Filterbedingung übereinstimmen, während des Abonnements der verschachtelten Observablen zu speichern. Hier

ein Beispiel:

const nested = Rx.Observable.from([1, 2, 3, 4, 5]); 

const stream = Rx.Observable.create((subscriber) => { 
    const saved = []; 

    const myData = nested.filter(x => x > 1).subscribe(x => { 
    subscriber.next(x); 
    saved.push(x); 
    }); 

    subscriber.complete(); 

    return() => { 
    myData.unsubscribe(); 
    //Here you have access to your data 
    console.log(saved); 
    } 

}); 

stream.subscribe(x => console.log(x));