javascript - 如何从 RxJs 中的 flatMap 返回附加值

Question

我需要从以下设置的 flatMap 返回 Observable、key 字符串以外的附加值:

this.subscribeInit = this.tradingService.getInProgress()
.pipe(flatMap((s) => {
    this.keys = s.map((tdi) => tdi.key);
    return this.keys;
}),
flatMap((key) =>{
    var res = this.tradingService.getTradingData(key);//returns `Observable<any>`
    return res;
}))
.subscribe(res => {
    console.log('Key is : ' + res.key);
}, 
undefined,
() => this.onComplete());

类似于:

flatMap((key) =>{
    var res = this.tradingService.getTradingData(key);
    return {res,key};
}))

如何实现这一目标？

Answer 1

只需使用 map ...

flatMap((key) =>{
    return this.tradingService.getTradingData(key).pipe(map((res) => {
        return {res,key};
    }));
}))

ps:我有点困惑:flatMap 是否已弃用并取代了我的 mergeMap、switchMap，...？

编辑:显然问题是由使用 flatMap 而不是 mergeMap 引起的。