本文介绍了我可以在“subscribe()”之前捕获某些错误吗?在Angular2中的RXJS可观察?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

在允许子类 subscribe 到observable之前,基类是否有可能 catch 某些错误Angular2。

Is it possible for a base class to catch certain errors before allowing the subclass to subscribe to the observable in Angular2.

例如

export class SomeBaseClass {
    constructor(private _http: Http, private _location: Location) {}

    protected _fetchData(url): Observable<any> {
        const headers = new Headers();
        headers.append('Authorization', 'Token foo');
        return this._http.get(url, {headers})
            .map(response => response.json())
            .catch(response => this._handle401(error));
    }

    private _handle401(response: Response) {
        if(response.status === 401) {
            this._location.go('/login');
        }

        // What should this return?
    }
}

export class SomeClass extends SomeBaseClass {
    constructor( _http: Http,  _location: Location) {
        super(_http, _location);
    }

    doTheThing() {
        this._fetchData('/someUrl')
            .subscribe(
                response => this._handleResponse(response),
                error => this._handleErrorThatIsNot401(error));
    }

    private _handleResponse(response) {
        // ...
    }

    private _handleErrorThatIsNot401(error) {
        // ...
    }
}

赶上我在找什么?我应该使用 map (或其他)吗?或者我是否完全以错误的方式解决这个问题?

Is catch what I am looking for? Should I be using map (or something else)? Or am I going about this the wrong way entirely?

两个答案(到目前为止)都把我在正确的轨道上,最终 - 我这样解决了:

Both answers (so far) put me on the right track, ultimately - I solved it like this:

protected _get(url: string, data?: any): Observable<any> {
    return super._get(url, data, this._authorizationHeader)
        .map(response => response.json())
        .catch(response => this._handle401(response));
}

private _handle401(response: Response): Observable<any> {
    try {
        if(response.status === 401) {
            this._router.navigateByUrl('/login');      
            return Observable.throw(response.status);  
        }
    } catch(err) {
        console.warn('AuthenticatedHttpService._handle401');
        console.error(err);
    }

    return Observable.of(response);
}


推荐答案

.catch()是正确的。

Observable 是懒惰的,所以在订阅之前没有错误。不确定你是否意味着这种之前因此我提到它只是为了确定。

Observable is lazy, so there are no errors before you subscribe. Not sure if you mean this kind of "before" therefore I mention it just to be sure.

这篇关于我可以在“subscribe()”之前捕获某些错误吗?在Angular2中的RXJS可观察?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!

10-22 20:12