创建 observable，订阅并返回

Question

我有以下问题： 我需要发送 POST 请求以从 oAuth 获取令牌。后来我想通过另一个服务创建用户上下文。但是我仍然需要保留 Observable，因为我想对组件的响应做出反应。

这是正确的做法吗？

login(username, password): Observable<any> {
  let response$ = this._http.post(params)
    .map((response: Response) => response.json());

  response$.subscribe(v => this._userService.doSmth());

  return response$;
}

编辑：

我根据@Maximus 的响应找到了另一种方法。没错——我只想提出一个要求。所以我写了这样的东西：

let response$ = this._http.post(data)
  .map((response: Response) => response.json());

let user$ = new Subject<User>();

response$.subscribe(v =>
  this._userService.createNewSession(v) // returns observable
    .subscribe(u => user$.next(u))
);

return user$.asObservable();

这样好吗？

Answer 1

这段代码：

let response$ = this._http.post(params).map((response: Response) => response.json());

建立一个不做任何事情的可观察链。一旦有人订阅它，它就会发送http请求。这就是这里发生的事情：

response$.subscribe(v => this._userService.doSmth());

但response$ 指向该链，而不是返回的值。如果其他人再次订阅response$，则会发出新的请求。

如果您想允许订阅response$ 并希望系统的其他部分能够访问该值，您应该使用AsyncSubject：

let subject = new AsyncSubject();
let response$ = this._http.post(data).map((response: Response) => response.json()).subscribe(subject);
response$.subscribe(v => this._userService.createNewSession(v));

return response$;