Góc 2 rxjs lồng nhau Quan sát

Question

Tôi muốn tạo hàm trả về Observable<any> nhưng trước khi trả lại tác vụ không đồng bộ khác phải hoàn thành (Observable<string>), để giá trị được chuyển đến số Observable trả lại.

@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); 
      }) 
     }   


} 

Vì vậy, thay vì đi qua các tham số authToken vào chức năng GetData, tôi muốn thực hiện chức năng GetAuthToken bên trong hàm GetData, chờ đợi để hoàn thành nó, và sau đó vẫn trả lại http thể quan sát được.

Thực thi các hàm DoIt sẽ trở về thuê bao, không phải là GetData Quan sát

Answer 1

Hãy thử sử dụng concatMap():

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

Answer 2

này cũng có thể sử dụng flatMap

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