RxJS Observable 和 Observer 问题

Question

我有一个 Angular 2 服务，它执行几个步骤来验证和登录应用用户。每当我尝试在我的观察者上调用 next() 时，我都会收到一个未定义的错误。当 Observable 被实例化时，我唯一可以成功调用 next() 的地方是在构造函数内部。

如果我调用 authenticateUser()，我会收到 this.isLoggedIn 未定义的错误。

AuthService.ts

public isLoggedIn$: Observable<boolean>;
private isLoggedIn: Observer<boolean>;

constructor(...) {

    this.isLoggedIn$ = new Observable<boolean>(
        (observer: Observer<boolean>) => {
            this.isLoggedIn = observer;

            // this works fine
            this.doLogin();

        }).share()

}

private doLogin = ():void => {

    let context:AuthContextModel = this.authContextService.getAuthContext();

    if (context) {

        let isAuthenticated = this.isAuthenticated(context);

        if (isAuthenticated) {

            this.doCreateCurrentUserContext(context)
                .then((result) => {return this.doNotifyLoggedInStatus(result);});
        }
    }
};


private doNotifyLoggedInStatus = (result:boolean):Promise<boolean> => {

    this.isLoggedIn.next(result);

    return new Promise((resolve, reject) => {
        return resolve(true);
    });
};


public authenticateUser = (user: string, pass: string):Promise<boolean> => {
    return this.doFetchToken(user, pass)
        .then((fetchTokenData) => {return this.doStoreToken(fetchTokenData);})
        .then((authContext) => {return this.doCreateCurrentUserContext(authContext);})
        .then((result) => {return this.doNotifyLoggedInStatus(result);});

};

Answer 1

如果你想在 Observable 实例化之外的 Observer 上调用 .next()，你应该使用 Subject 而不是单独的 Observables 和 Observers。受试者两者兼而有之。您可以在将事件传递给它的位置单独订阅它们。

有不同种类的主题，但对于您的情况，我会推荐一个 BehaviorSubject。每当您订阅它时，它不仅会捕获未来的事件，还会返回在订阅发生之前触发的 last 事件。这对于身份验证组件很有用，因为您不必为成功登录编写单独的代码并实际检查用户是否在已经发生（或稍后注销）后通过身份验证。这也很简单。

import { BehaviorSubject } from 'rxjs/Rx'; 

//...
  public isLoggedIn: BehaviorSubject<boolean> = BehaviorSubject.create();

  constructor(...) { }

  private doLogin():void {

    //... Do the log in
    this.isLoggedIn.next(true);

  };

无论您想检查登录状态，您需要做的就是获取 BehaviorSubject 并订阅它。订阅是在调用 doLogin() 之前还是之后发生都没有关系。

如果您打算在刷新时保留登录状态，您只需在构造函数中检查身份验证并照常调用 BehaviorSubject 上的.next(true)。

另见：

ReactiveX Subject docs

Intro to Rx BehaviorSubjects