Filter eine beobachtbare durch eine beobachtbare

Question

Lassen Sie uns die folgende vereinfachte Situation berücksichtigen:

• Wir haben eine beobachtbare Äpfel vom Typ beobachtbare < Apfel>
• Jedes Apple-Objekt verfügt über eine Methode isRotten(), die gibt einen beobachtbaren von Typ Observable < Boolean> welcher garantiert mindestens einen booleschen Wert ausgibt.

Ich möchte die beobachtbaren Äpfel so filtern, dass die faulen Äpfel den Filter nicht passieren. Genauer gesagt, ein Apfel A passiert den Filter genau dann, wenn der erste von A.isRotten() ausgegebene Gegenstand falsch ist. Was ist der beste Weg, diesen Filter zu implementieren?

Nach einiger Überlegung konnte ich mit diesem kommen:

apples 
    .concatMap(apple => 
     apple.isRotten() 
      .first() 
      .filter(bool => bool) 
      .map(bool => apple)) 

, die in Javascript geschrieben. (... => ... ist eine Funktion). Das funktioniert, aber ich denke, es ist ziemlich lang und schwer zu verstehen. Gibt es einen besseren Weg, um so etwas zu tun?

Answer 1

Was du hast, sind in Ordnung und TBH, ich nicht von einer prägnanten Art und Weise, es zu tun denken. Ich würde wahrscheinlich flatMap anstatt concatMap verwenden, wenn Out-of-Order-Äpfel kein Problem sind.

Wenn Lesbarkeit ein Problem für Sie ist, bewegen sich nur die Umsetzung in es ist eine Funktion (zB. filterObservable, die eine Funktion übernimmt, die einen Wert nimmt und gibt ein IObservable<bool>)

Answer 2

Sie können etwas tun:

var seq = Rx.Observable.from([1, 2, 3, 4, 5, 6]) 
    .filter(x => { 
     let isRotten = true; 
     Rx.Observable.just(x % 2 === 0) 
      .first() 
      .subscribe(val => isRotten = val); 

     if (isRotten) { 
      return x; 
     } 
    }); 

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