gunwin gunwin - 1 year ago 253
Javascript Question

Angular 2 rxjs nested Observables

I wish to create a function that returns an

but before returning another asyncronous task must complete (an
), in order for a value to be passed to the returned

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


So instead of passing the authToken parameter into the GetData function, I wish to execute the GetAuthToken function within the GetData function, wait for its completion, and then still return the http observable.

Executing the DoIt function would return the subscriber, not the GetData Observable

Answer Source

Try using concatMap():

DoIt() : Observable<any>
    return this.GetAuthToken()
        .concatMap(token => this.GetData(token)); 
Recommended from our users: Dynamic Network Monitoring from WhatsUp Gold from IPSwitch. Free Download