Как дождаться окончания вложенного forkjoin?

Question

У меня проблема с вложенным forkjoin, когда я пытаюсь подписаться на pull, он возвращает мои данные, но я вижу, что getitem3 все еще работает. Как ждать, пока все функции закончены до подписываться

см пример

pull(id) { 
    return Observable.forkJoin(
    this.getitem1(id), 
    this.getitem2(id), 
    this.getitem3(id) 
); 
} 



getitem3(id) { 
    let url = 'https://host3/get/' + id; 
    let observableBatch = []; 

    return this.http.get(url).map(res => res.json()).map(data => { 
    data.posts.data.forEach((item) => { 
     observableBatch.push(this.getImageUrl(item.id)); 
    }) 
    return Observable.forkJoin(observableBatch); 
    }) 
} 


getitem2(id) { 
    let url = 'https://host2/get/' + id; 
    let observableBatch = []; 

    return this.http.get(url).map(res => res.json()).map(data => { 
    data.posts.data.forEach((item) => { 
    observableBatch.push(this.getImageUrl(item.id)); 
    }); 
    return Observable.forkJoin(observableBatch); 

    }); 
} 

getitem1(id) { 
    let url = 'https://host1/get/' + id; 
    let observableBatch = []; 

    return this.http.get(url).map(res => res.json()).map(data => { 
    data.posts.data.forEach((item) => { 
     observableBatch.push(this.getImageUrl(item.id)); 
    }); 
    return Observable.forkJoin(observableBatch); 
    }); 
} 

getImageUrl(id) { 
    let url = 'https://localhost/image/' + id; 
    return this.http.get(url).map(res => res.json()).map(data => { 
    console.log('done'); 
    }); 
} 

Answer 1

Я думаю, что ваши методы getitemN() возвращает Observable <Observable<any>>. И когда вы подписываетесь, вы просто вызываете первый наблюдаемый, чтобы позвонить другим, вы можете использовать flatMap вместо map.

.flatMap(data => { 
       data 
        .posts 
        .data 
        .forEach((item) => { 
         observableBatch.push(this.getImageUrl(item.id)); 
        }) 
       return Observable.forkJoin(observableBatch); 
      }) 

Так что в этом случае вы получите только Observable <any>.

Полезная информация: http://www.syntaxsuccess.com/viewarticle/angular-2.0-and-http. FlatMap находится в разделе «Зависимые вызовы».