假设我有一个函数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/