operators - 如何获得 react 流中最后两个项目的滚动缓冲区？

Question

我有一个发出数字x的流。我想要的是dx（x的差异），所以我需要一个滚动缓冲区，该缓冲区发出x_n和x_(n-1)以便映射到dx = x_n - x_(n-1)。在大理石图中，这看起来像...

SOURCE --A------B------C--------D------F--G-----

RESULT ---------AB-----BC-------CD-----DF-FG----

这对于滚动平均等其他操作非常方便。

我已经检查了 operator docs，但似乎找不到任何类似的东西。 sample有点接近，但与时间有关。 buffer也很接近，但是严格地将值排队，缓冲区之间没有重叠。

我正在使用RxJS

Answer 1

RXJS 4

您甚至可能不需要buffer，一个简单的concatMap可能对您有用（当然，我不知道您的流的任何详细信息：

observable = Rx.Observable.from(["A", "B", "C", "D", "E", "F"]);

observable
  .bufferWithCount(2, 1)
  .subscribe(all => {
    console.log(all);
});

查看实时 here