rxjs - 缓存来自 BehaviorSubject 的管道结果

Question

使用 rxjs，我有一个昂贵的计算来映射来自 BehaviorSubject 的结果。 :

const obs$ = sameBehaviorSubject.pipe(map(expensiveComputation));

然后在我的代码的多个其他部分中，我订阅了该 observable。每次我订阅时，它都会重新运行 expensiveComputation .我怎样才能防止这种情况？

Answer 1

您可以使用 shareReplay:

const obs$ = sameBehaviorSubject.pipe(map(expensiveComputation), shareReplay(1));

现在您可以订阅 obs$多次不做 expensiveComputation多次。