RxJS - Catch i prowadzić

Question

jestem stara się obsłużyć błędy z Rx w sposób spodziewałem.

Kiedy mają widoczny (na przykład ze strumienia click) i wystąpi wyjątek chcę go złapać, ale prowadzić. Wszystkie rozwiązania, które próbowałem złapać błąd, a następnie zakończyć obserwowalne. Czy istnieje sposób na złapanie i kontynuowanie?

Jako przykład, poniżej Obserwowalne emituje „1”, a następnie „Error”, a nie „3”.

var range = Rx.Observable.range(1,3) 
    .map(function(i){ 
     if(i === 2){ 
     throw "Error"; 
     } else { 
     return i; 
     } 
    }) 
    .catch(function(e){ 
     return Rx.Observable.return(e) 
    }); 

range.subscribe(function(i){ 
    console.log(i) 
}); 

Answer 1

Podczas gdy spodziewane zachowanie nie może być osiągnięta ze względu na obserwowalnych umowy (OnNext)* (OnCompleted|OnError), istnieją praktyczne sposoby wokół to właściwie działa poprzez wprowadzenie gorący widoczne.

let hotRange = Rx.Observable.range(1,3).publish(); 

let safeRange = hotRange 
    .map(function (i) { 
    if (i === 2) { 
     throw "Error"; 
    } else { 
     return i; 
    } 
    }) 
    .retry(); 

safeRange.subscribe(i => console.log(i)); 
hotRange.connect(); 

See the JSBin. Obwieszczenie, o którym wspomniałeś w pytaniu, jest zimne Obserwowalne. To behaves as a movie, więc jeśli błąd się dzieje, a my ponownie zarejestrować, musimy zapisać się od początku „Film”, czyli 1 następnie "Error".

Prawdopodobnie miałeś domyślne założenie, że Rx.Observable.range(1, 3) było Live Observable, tj. "Hot". Ponieważ nie jest, zrobiłem hotRange powyżej, używając publish(). W ten sposób będzie emitował swoje wydarzenia niezależnie od swoich subskrybentów. Jeśli chcemy mieć możliwość "kontynuacji" po błędzie, potrzebujemy naszego źródła ("hotRange") bez błędów. Dlatego range.map() nie jest gorący Obserwowalny. retry() będzie przechwytywać błędy na hotRange.map() i zastąpić je hotRange.map(). Ponieważ hotRange jest gorący, każdy wykonanie retry() będzie inny, ponieważ nie pamięta poprzednie wartości emitowanych przez hotRange. Więc gdy błąd spowodowany 2 zastępuje hotRange.map() w ponawiania, hotRange będzie następnie emitują 3 i przekazać funkcję mapa bez błędów.