角2 rxjsネストされたオブザーバブル

Question

返されるObservableに値を渡すために、Observable<any>を返しますが、別の非同期タスクを完了する必要がある（Observable<string>）を返す関数を作成したいとします。

@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関数にauthTokenのパラメータを渡す、私はのGetData関数内GetAuthToken機能を実行したい、その完了を待って、まだ観察できるHTTPを返します。 、ではないのGetDataが観察加入者を返すドイト機能を実行

Answer 1

concatMap()を使用してみてください：

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

Answer 2

をこれがflatMap

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