RxJS和AngularJS HTTP – 我该如何实现？

我正在编写一个小实用程序函数,它使用必要的身份验证标头包含对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');
}

(...)

这样将调用subscribe方法的第二种方法：

observable.subscribe(
  (data) => {
    (...)
  },(err) => {
    // Will be called in this case
  }
);