javascript – Angular 2 rxjs嵌套的Observables

我希望创建一个返回Observable< any>的函数.但在返回另一个异步任务之前必须完成(一个Observable< string>),以便将值传递给返回的Observable.

@Injectable()
 export class MyComponent
 {

      GetAuthToken = function() : Observable<string>
      {
           return this._storageService.GetAsstring('authToken');
      }

      GetData = function(authToken) : Observable<any>
      {

           let headers = new Headers();
           headers.append('authToken',authToken);
           var getUsers = this._http.get('/api/endpoint',{ headers: headers })
                 .map((resonse: Response) => resonse.json()));

           return getUsers;        
      }


      DoIt = function() : Observable<any>
      {
          this.GetAuthToken ().Subsribe(t=> {
              return GetData(t); 
          })
      }          


 }

因此,我希望在GetData函数中执行GetAuthToken函数,等待其完成,然后仍然返回http observable,而不是将authToken参数传递给GetData函数.

执行DoIt函数将返回订阅者,而不是GetData Observable

解决方法

尝试使用 concatMap()：

DoIt() : Observable<any>
{
    return this.GetAuthToken()
        .concatMap(token => this.GetData(token)); 
}