如何等待嵌套forkjoin完成？

Question

我有一個嵌套的forkjoin的問題，當我嘗試訂閱拉，它回來我的數據，但我可以看到，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位於「從屬電話」部分。