扁平Observable<Observable<Object[]>>
扁平Observable<Observable<Object[]>>
提问于 2017-01-13 21:00:57
我正试图在Firebase中创建一个连接。
因此，我异步地从db获取id数组，然后对每个id异步加载实际对象。函数应该返回可观测的
因此，对于第一个异步请求，我将得到可观察的(string是id)。所以，无论我在这里尝试了什么，我都可以观察到，或者其他一些我不想得到的东西。
守则：
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[]>'.
回答 1
Stack Overflow用户
回答已采纳
发布于 2017-01-14 06:40:44
您可以使用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)))
...页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/41643354
复制相关文章
相似问题
腾讯云开发者
