angular - RxJs : Incrementally push stream of data to BehaviorSubject<[]>

Question

基本上我正在尝试膨胀 BehaviorSubject<[]>包含数据数组，这些数据将分块加载。

BehaviorSubject<[]>将添加新的数据 block (如 Array.push )但我不想使用另一个数组来存储和添加到 BehaviorSubject.next因为这会导致渲染时间过长，因为数据会随着时间的推移而增长。

有什么建议吗？

Answer 1

您可以使用getValue() 方法来实现您想要做的事情。

例子:

data = new BehaviorSubject<any[]>([]);

addData(foo:any):void{
  // I'm using concat here to avoid using an intermediate array (push doesn't return the result array, concat does).
  this.data.next(this.data.getValue().concat([foo]));
}