Push neue Observablen auf der Grundlage der Eingabe von vorherigen in RxJS

Question

Ich finde es schwierig, ein Thema zu komponieren oder beobachtbar, wo ich Validierung habe. Dies ist die Natur der funktionalen Programmierung, aber es scheint, dass die reaktive Programmierung nur für jedes Datenelement sorgt. Außerdem sind die Beispiele ein bisschen zu allgemein, kein reales Beispiel, das viele Aspekte abdeckt, obwohl dies eine persönliche Meinung ist.

Ich würde gerne einen anderen Wert an den Beobachter senden, basierend auf dem vorherigen, aber ich kann nicht herausfinden, wie dies zu erreichen ist.

Rx.Observable.create(function(obs) { 
    obs.next(1) 
    // if value is one, compile 3, if not, respond with 2 
    obs.next(someVal) 
    obs.onCompleted() 
}); 

Answer 1

Sie würden finden es einfaches Thema und Karte zu verwenden:

let src = new Subject<number>(); 
let other = src.map(v => (v === 1 ? 3 : 2)); 

other.subscribe(v => console.log(v)); 

src.next(1);// prints 3 
src.next(4);// prints 2