Angular 6 / RxJs 6 Observable合并也会跳到错误块

Question

我的身份验证服务中有一个登录功能，如果登录完成或返回HttpError，我希望它返回一些值。这一步很简单，我也希望包括初始登录是否有效，使用第二个observable加载帐户详细信息。此步骤对我不起作用，因为如果登录失败，代码也不应尝试加载帐户详细信息。我尝试使用合并功能，但是当发生错误时，它仍然会调用另一个可观察的。即使登录工作，我仍然永远不会从第二个observable得到延迟。

我很难适应Rxjs版本6的管道设置，并且有很多管道非常混乱。

登录方式：

    public Login(LoginData: LoginModel): Observable<HttpErrorResponse | LoginResponse>
  {
    var loginRequest = this.web.post<LoginResponse>('http://localhost:20552/api/token', LoginData).pipe(share());

    return loginRequest.pipe(map((success: LoginResponse) =>
    {
      return new LoginResponse(success.token);
    }), merge(this.LoadAccountDetails())).pipe(catchError((val: LoginResponse | HttpErrorResponse) => of(val))).pipe(map((x: LoginResponse | HttpErrorResponse) =>
    {
      if (x instanceof LoginResponse)
      {
        return new LoginResponse(x.token);
      } else
      { 
        var error = x as HttpErrorResponse;
        return error;
      }
    }));
  }


  public LoadAccountDetails(): Observable<any>
  { 
    return of({}).pipe(delay(5000)); // Simple delay function because I haven't finished this server code yet.
  }

Answer 1

这取决于错误是作为next或error通知发出的，但是从这个例子中很难说。

另外问题可能是您可能想要使用mergeMap而不是merge，因为merge在创建链时会立即订阅，这通常不是您想要的。

如果你使用mergeMap(() => this.LoadAccountDetails())它只会在它的源发出next值时调用回调。