RxJS可观察，从第一次发射开始发射先前和当前值

Question

我有一个定期发出JavaScript对象的行为主题。我想构建另一个可观察对象，它将发出底层可观察对象的先前和当前值，以便比较两个对象并确定增量。

pairwise（）或bufferCount（2，1）操作符看起来很合适，但它们只有在缓冲区填满后才开始发出，但我要求这个可观察对象从基础可观察对象的第一个事件开始发出。

subject.someBufferingOperator()
    .subscribe([previousValue, currentValue] => {
        /** Do something */
    })
;

在第一次发射时，previousValue可能只是null。

是否有一些内置的运算符，我可以使用以达到预期的结果？

Answer 1

下面是一个简单的运算符：

function withPreviousItem<T>(): OperatorFunction<
  T,
  {
    previous?: T;
    current: T;
  }
> {
  return pipe(
      startWith(undefined),
      pairwise(),
      map(([previous, current]) => ({
        previous,
        current: current!
      }))
    );
}

这样做的好处是，结果具有有意义的属性名称和正确的类型：

• 之前的是T|未定义
• 当前是T（不是T|null）

Stackblitz示例

Answer 2

以下是rxjs 6的代码片段

subject
    .pipe(
       startWith(undefined),
       pairwise()
    )
    .subscribe(([previousValue, currentValue]) => {
        /** Do something */
    });

因为没有值，所以startWith（）中的值应该是未定义的。通常，null定义为“我们有一个值，这个值为空”。

Answer 3

实际上，它就像将成对（）与start For（）运算符配对一样简单：

subject
    .startWith(null) // emitting first empty value to fill-in the buffer
    .pairwise()
    .subscribe([previousValue, currentValue] => {
        if (null === previousValue) {
            console.log('Probably first emission...');
        }
    })
;