假设我有一个函数GetUserRecommendedSongs。它执行以下操作:


它向用户显示一个对话框:您今天的心情如何?
(快乐\沮丧\怀旧)
使用结果,它将调用服务GetUserRecommendationsByMood
然后返回一个结果,例如:{mood: "nostalgic", songIds:[12, 25]};
此函数的调用者(可能有多个ui组件)将
使用结果播放标题为"so you feel ${result.mood} today?"的歌曲


问题是我两次使用了心情:得到建议,最后得到结果。

使用async\await我会做:

const requiredMood = await ShowRequiredMoodDialog();
//handle cancellation e.g. if(!mood)
let recommendedSongs = await GetUserRecommendations(mood);
return {mood, recommendedSongs};


但是,使用rxjs我只能提出以下内容:

let mood$ = ShowRequiredMoodDialog().pipe(share) //has to be shared so we don't show the dialog twice
let recommendedSongs$ = mood$.pipe(switchMap((mood)=> GetUserRecommendations(mood)));
return forkJoin(mood$, recommendedSongs$) //with some selector\map to turn into object


(给读者的提示:不要使用它作为对rxjs的引用,因为我没有测试此代码)

此代码非常复杂。可以简化吗?

最佳答案

我想到的唯一不同的方式是这样的,但我不知道哪个更易读:

mood$.pipe(
  switchMap(mood => GetUserRecommendations(mood).pipe(
    map(recommendedSongs => [mood, recommendedSongs]),
  ),
)

关于javascript - RXJS:在运算符之间分配然后重用值,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/54168586/

10-12 12:39
查看更多