Angular2 ngrx/store有多次登錄嘗試

Question

通過幾個ngrx示例（https://github.com/SekibOmazic/ngrx-auth-example）和（https://github.com/ngrx/angular2-store-example），他們都創建了對商店的訂閱，然後進行REST API調用。

我修改了他們的代碼以返回錯誤，但訂閱仍保持機智（例如，嘗試登錄時返回404）。我可以在控制檯中看到錯誤，但我可以再次登錄。

在我的代碼中，我有一個幾乎相同的設置，但失敗的登錄響應殺死我的訂閱（盡我所知）。

我需要什麼魔法才能使4XX錯誤響應代碼不殺我的訂閱？

private actions$ = new BehaviorSubject<Action>({ type: actions.INIT, payload: null }) 

constructor(
    public http: Http, 
    private store: Store<AppStore> 
) { 
    let logins = this.actions$ 
    .filter(action => { debug('ACTION', action); return action.type === actions.LOGIN_USER }) 
    .do(() => { debug('DISPATCH'); this.store.dispatch({ type: actions.LOGIN_REQUEST }) }) 
    .mergeMap(action => this.http.post('/auth/login', JSON.stringify(action.payload))) 
    .share(); 

    let loginSuccess$ = logins 
    .filter((payload: IResponse) => payload.data.token !== null) 
    .map((payload: IResponse) => ({ type: actions.USER_AUTHENTICATED, payload: payload.data })); 

    let loginFailure$ = logins 
    .filter((payload: IResponse) => payload.data.token === null) 
    .map((payload: IResponse) => ({ type: actions.LOGIN_FAILURE, payload: payload.data })); 

    Observable 
    .merge(loginSuccess$, loginFailure$) 
    .subscribe((action: Action) => this.store.dispatch(action)) 
} 

login(payload: ILogin) { 
    this.actions$.next({ type: actions.LOGIN_USER, payload }); 
} 

Answer 1

這是更多與RxJS本身，而不是任何與ngrx。除非您a）在.subscribe（next，err）處理程序中處理它，或者使用.catch（）運算符或類似方法，否則錯誤會結束流。

例如

let loginFailures$ = http.get('failurl') 
    .map(res => res.json()) 
    //handle error with catch 
    .catch(err => { 
    //return a 'fixed' observable 
    return Observable.of({ type: actions.LOGIN_FAILURE, payload: err }) 
    }) 
    .subscribe(action => store.dispatch(action));