javascript - RXJS:在运算符之间分配然后重用值

Question

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

1. 它向用户显示一个对话框:你今天心情如何？(快乐\忧郁\怀旧)
2. 使用结果调用服务 GetUserRecommendationsByMood。
3. 然后它返回一个结果，例如:{mood: "nostalgic", songIds:
[12, 25]};
4. 这个函数的调用者(可能是几个 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 的引用，因为我没有测试此代码)

这段代码相当复杂。可以简化吗？

Answer 1

我想到的唯一不同的方式是这样的，但我不知道哪种方式更具可读性:

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