RxJs detecta error y continúa
Tengo una lista de elementos para analizar, pero el análisis de uno de ellos puede fallar.
¿Cuál es el "Rx-Way" para detectar el error pero continuar ejecutando la secuencia?
Código de muestra:
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>
Lo que quiero hacer de una manera no Rx:
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);
}
}
Gracias por adelantado