我正在编写一个小实用程序函数,它使用必要的身份验证标头包含对AngularJS http.get的调用:
get(endpoint: string): Observable { var headers = new Headers(); this._appendAuthentificationHeaders( headers,this.user.credentials); return this.http.get(endpoint,{ headers: headers }) .map(res => res.json()); }
这里的要点是,如果this.user为null,则该方法将崩溃.
所以我有三个选择:
>返回null并检查每次调用的返回值…
>抛出异常
>找到一种方法来返回一个直接触发错误处理程序的RxJS Observable对象.
我想实现第三种方法,因为它允许我统一这个方法的行为:无论发生什么,它总是返回一个observable.
>你对如何做到这一点有所了解吗?
>我是否必须创建一个新的Observable并将这两个合并?
>我该怎么办?
如果用户为null,则只需返回触发错误的原始observable:
if (this.user == null) { return Observable.create((observer) => { observer.error('User is null'); }); } (...)
或利用throw运算符:
if (this.user == null) { return Observable.throw('User is null'); } (...)
observable.subscribe( (data) => { (...) },(err) => { // Will be called in this case } );