RxJS获取可观测的发射前/后值

Question

我想计算单个可观测物体的排放量之间的差异。

如果一个可观测的物体发出一个新的值，有没有办法同时得到它当前和以前的发射？我想要这样的东西：

ob$.subscribe(val => {
  console.log(val)
  // First emission: [1,2,3]

  // Second emission: [1,2,3,4]

  console.log(arrayDifference(before, after)) // [4]
})

我该怎么做呢？我是否需要将每个发射存储在一个上限变量中，或者是否有一种奇特的RxJS方法来实现这一点？

Answer 1

我会使用startWith和pairwise（）

 const randomObservable = of('observableString')
  .pipe(startWith('defaultString'), pairwise())
  .subscribe(arrayOfStrings => console.log(arrayOfStrings[0], arrayOfStrings[1]));

上面的代码将控制台日志：“defaultString”，“observableString”。

Answer 2

您可以使用非常模块化的bufferCount运算符来实现这一点：

bufferCount(2, 1)

它将在源的每次1发射后创建一个大小为2的新缓冲区。

或者，也有执行完全相同操作的成对（）运算符。

Answer 3

使用扫描操作员检查上一个值

   const arrayDifference = (before, after) => {
    // Immlement the fuction here
    
    const difference = .........
    return difference
    }
    
    
    ob$.pipe(scan((before,after) => arrayDifference(before,after), [])).subscribe(val =>  console.log(val))

这应该行得通