多次通知时behaviorSubject的下一次调用延迟- Angular，Rxjs

Question

在我的角度应用程序中，我将状态作为 BehaviorSubject 存储在服务中，当数据来自服务器时，我调用下一个函数来更新数据并通知所有订阅者。

伪代码：

   ajaxCall_1 -> updateData(response2)
   ajaxCall_2 -> updateData(response2)
   ajaxCall_3 -> updateData(response3)
   ...
    
private data$:Observable<any>;
public updateData(newData){
var currentData = data$.value;
data$.next({...currentData , ...newData})
}

由于很多组件都订阅了该 BehaviorSubject，我认为在我的应用程序加载时可能会导致一些性能问题：在加载时，有很多来自服务器的通知，每次下一个函数称为组件时都会渲染。

你认为如果我将呼叫延迟到大约500毫秒后，我会看到性能提高吗？rxjs延迟下次通话的方式会是什么？

Answer 1

这里有一种方法可以决定updateData函数的调用频率（比如每秒一次）。

我在这里所做的是将所有调用缓冲一秒钟，然后将缓冲区缩减为一个对象，然后将该对象发送给updateData。

merge(
  ajaxCall_1,
  ajaxCall_2,
  ajaxCall_3,
  ...
).pipe(
  bufferTime(1000),
  filter(buffer => buffer.length > 0),
  map(bufferedNewData => bufferedNewData.reduce(
    (acc, curr) => ({...acc, ... curr}), {}
  ))
).subscribe(updateData);

另一方面，在第一组调用全部完成之前不显示任何内容可能是有意义的。这可能会使初始负载更可预测。这只是一个微小的变化：

forkJoin([
  ajaxCall_1,
  ajaxCall_2,
  ajaxCall_3,
  ...
]).pipe(
  map(loadNewData => loadNewData.reduce(
    (acc, curr) => ({...acc, ... curr}), {}
  ))
).subscribe(updateData);

Answer 2

性能影响将来自订阅该行为主体的组件，而不是其本身。

无论如何，您可以使用延迟运算符来延迟下一个呼叫，如下所示：

private sub$ = new BehaviorSubject<any>(null);
public data$ = this.sub$.pipe(delay(500)));

public updateData(newData){
  var currentData = sub$.value;
  sub$.next({...currentData , ...newData})
}