ObservableストリームをObservable Arrayに変換する方法

Question

データベースから犬のリストを取得しようとしています。私はObservable<Dog[]>として犬のリストを取得したいと思います。しかし、私がtoArray（）を呼び出したり、配列に入ってくるストリームを変換しようとする他のメソッドを使ったりすると、retrieveDogs(dogsId)メソッドを呼び出すときにデータを受け取らなくなります。 Observable streamの代わりにObservable arrayを取得するにはどうすればよいですか？

retrieveDogs(dogIds : Array<string>): Observable<Dog[]>{ 
     return Observable.from(dogIds) 
       .map(dogId => this.retrieveDog(dogId)) 
       .flatMap(dogObservable => dogObservable) 
       .toArray(); 
    } 

    retrieveDog(dogId : string) : Observable<DogEntity> { 
    //afDB -> AngularFireDatabase that returns an observable with the data from the firebase database 
     return this.afDB.object(DB_DOGS + DB_DASH + dogId) 
       .map(dogObject =>DogEntity.convertObject(dogId,dogObject) 
    } 

Answer 1

あなたはあなたのデータを取得するためにそれを行うことができます：

retrieveDogs(dogIds : Array<string>): Observable<Dog[]>{ 
    let obs = dogIds.map(dogId => this.retrieveDog(dogId)); 

    return Observable.forkJoin(obs); 
} 

retrieveDog(dogId : string) : Observable<DogEntity> { 
    return this.afDB.object(DB_DOGS + DB_DASH + dogId) 
    .map(dogObject => DogEntity.convertObject(dogId,dogObject)); 
} 

簡単なデモここhttp://jsbin.com/sotunopocu/2/edit?js,console