RxJs Fehler abfangen und fortfahren

Ich habe eine Liste der zu analysierenden Elemente, aber das Parsen eines dieser Elemente kann fehlschlagen.

Was ist der "Rx-Weg", um einen Fehler abzufangen, aber die Ausführung der Sequenz fortzusetzen

Code Sample:

var observable = Rx.Observable.from([0,1,2,3,4,5])
.map(
  function(value){
      if(value == 3){
        throw new Error("Value cannot be 3");
      }
    return value;
  });

observable.subscribe(
  function(value){
  console.log("onNext " + value);
  },
  function(error){
    console.log("Error: " + error.message);
  },
  function(){
    console.log("Completed!");
  });
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/4.0.6/rx.all.js"></script>

Was möchte ich auf eine andere Weise tun:

var items = [0,1,2,3,4,5];

for (var item in items){
  try{
    if(item == 3){
      throw new Error("Value cannot be 3");
    }
    console.log(item);
  }catch(error){
     console.log("Error: " + error.message);
  }
}

Danke im Vorau

Antworten auf die Frage(6)

Ihre Antwort auf die Frage