Flatten Observable <Observable <Object[]>>

Question

我試圖在Firebase中創建一個連接。

因此，我異步地從數據庫中獲取ID數組，然後爲每個ID然後異步加載實際的對象。並且該函數應該返回Observable

因此，通過第一個異步請求，我得到了Observable（字符串就是id）。 所以，無論我在這裏嘗試，我要麼Observable或其他一些不是我想要得到的東西。

的代碼：

getUserFavourites(userId = ""):Observable<any[]> { 
    return this.af.database.list('/ranks_by_user/likes/'+userId, { 
    query: { 
     orderByKey: true, 
     limitToFirst: 50 
    } 
    }).flatMap((likes:any[]) => { 
    return like.map(like => { 
     return this.af.database.object("/citations/" + like.$key) 
    }); 
    }); 
} 

和錯誤是：

Type 'Observable<FirebaseObjectObservable<any>>' is not assignable to type 'Observable<any[]>'.

Answer 1

可以使用forkJoin獲得引文的陣列。注意，first操作者被用來獲得從所述object可觀測量的電流值，作爲forkJoin需要可觀測量來完成：

import { Observable } from "rxjs/Observable"; 
import "rxjs/add/observable/forkJoin"; 
import "rxjs/add/operator/first"; 
import "rxjs/add/operator/switchMap"; 

getUserFavourites(userId): Observable<any[]> { 
    return this.af.database.list('/ranks_by_user/likes/' + userId, { 
    query: { 
     orderByKey: true, 
     limitToFirst: 50 
    } 
    }) 
    .switchMap((likes: any[]) => Observable.forkJoin(
    likes.map(like => this.af.database.object("/citations/" + like.$key).first()) 
)); 
} 

forkJoin花費可觀的陣列，並返回可觀察到的發射的可觀察的最終的陣列值。

如果您要返回Citation實例，則需要創建它們（假定使用數據庫中的值）。您可以使用map運算符來執行此操作：

import "rxjs/add/operator/map"; 
... 
likes.map(like => this.af.database.object("/citations/" + like.$key).first().map(value => new Citation(value))) 
...