RXJS CombinAtest仅将计时器添加到一个可观察的

Question

我有两个实体， games 和大奖：
游戏界面

{
    id: string,
    name: string
}

奖金接口

{
    game: string,
    amount: number
}

首先，我有两个可观察，一个可以获得游戏，一个获得 jackpots 。
在获取数据后，我想将 jackpots 的数据合并到基于 id 的 Games 中。而且，由于jackpots observale应该在每秒钟内获取数据，所以我使用操作员计时器来做到这一点。因此，这是我的实现：

private getGames = (category: string): Observable<IGame[]> => {
        return timer(0, 3000).pipe(
            mergeMap(() => combineLatest([this.gameService.getGames(), this.gameService.getJackpots()])),
            map(([games, jackpots]) => {
                return games?.filter(game => game?.categories?.includes(category))?.map(game => {
                    return { ...game, jackpot: jackpots?.find(jackpot => jackpot?.game === game?.id) };
                })
            })
        );
    };

此实现效果很好，并且每3秒获取数据。现在，正如您可以看到 Games 和 jackpots 可观察到的可观察每3秒钟，我的问题是：有没有办法只运行 jackpots 每3秒钟可观察一次，并从该计时器中排除游戏可观察到的。

Answer 1

上下文

combineLatest 具有两个重要属性：

• 每当观察物发出值时，它会发出。
• 它要求所有源可观察到至少发出一个值。

解决方案

您只能为 Games 可观察的计时器设置，并将其与 jackpots One组合。

private getGames = (category: string): Observable<IGame[]> => {
  return combineLatest([
    timer(0, 3000).pipe(mergeMap(() => this.gameService.getGames())),
    this.gameService.getJackpots(),
  ]).pipe(
    map(([games, jackpots]) => {
      return games
        ?.filter((game) => game?.categories?.includes(category))
        ?.map((game) => {
          return { ...game, jackpot: jackpots?.find((jackpot) => jackpot?.game === game?.id) };
        });
    })
  );
};