RxJs Observable 如何处理成功

Question

有没有办法在 Angular 服务中而不是在 Angular 组件中（通过订阅）处理 RxJs POST 或 GET（或所有 CRUD 操作）的成功？

我想设置一个 BehaviorSubject 来发出用户已成功登录的信息。我正在考虑通过我的 BehaviorSubject (this.loggedIn.next(true)) 与各种同级组件分享成功结果，因为这些同级组件需要进行更改基于单个服务userLogin() 调用。

这是我的 AuthenticationService 中的 userLogin 方法和 BehaviorSubject：

private loggedIn = new BehaviorSubject<boolean>(false);

userLogin(user): Observable<any> {
return this.http
  .post(this.apiUrl, user, httpOptions)
  .pipe(catchError(this.handleError));
}

这是我想要的 AuthenticationService 的伪代码：

private loggedIn = new BehaviorSubject<boolean>(false);

userLogin(user): Observable<any> {
return this.http
  .post(this.apiUrl, user, httpOptions),
  this.loggedIn.next(true),            <<--------
  .pipe(catchError(this.handleError));
}

提前谢谢你！

Answer 1

你可以试试：

private loggedIn = new BehaviorSubject<boolean>(false);

userLogin(user): Observable<any> {
return this.http
  .post(this.apiUrl, user, httpOptions)
  .pipe(map((res: any) => {
                this.loggedIn.next(true)
                return res;
        }), catchError(this.handleError));
}

Answer 2

订阅后处理

    ngOnInit() {
            this.loading.present();
            this.yourService.getUsers().
                subscribe(data => {
                    console.log(this.data);
                },
               //Errr----->***      
              err =>{ console.log('HTTP Error', err),this.loading.dismiss()}
            );
        }

在服务中可以处理

https://scotch.io/bar-talk/error-handling-with-angular-6-tips-and-best-practices192

 handleError(error) {
    ///your error
       let errorMes = '';
       if (error.error instanceof ErrorEvent) {
         // client-side error
         errorMes = `Error: ${error.error.message}`;
       } else {
         // server-side error
         errorMes = `Error Code: ${error.status}\nMessage: 
         ${error.message}`;
       }
       window.alert(errorMes);
       return throwError(errorMes);
     }