Açısal 2 rxjs yuvalanmış Gözlemler

Question

Observable<any> döndüren bir işlev oluşturmak istiyorum, ancak döndürülen Observable için bir değerin geçirilmesi için başka bir asenkron görev döndürmeden önce tamamlanmalıdır (bir 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); 
      }) 
     }   


} 

Bunun yerine GetData işleve Kimlik Doğrulama Simgesi parametresini geçme, ben GetData işlev içinde GetAuthToken işlevini yürütmek isteyen, tamamlanmasını bekleyin ve sonra yine gözlemlenebilir http dönün. Değil, GetData gözlemlenebilir aboneyi dönecekti DoIt fonksiyon komutunun

Answer 1

concatMap() kullanmayı deneyin:

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

Answer 2

Bu flatMap

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