Rxjs `distinctUntilChanged()` 似乎不起作用

Question

在 rxjs 流中，我使用distinctUntilChangedlodashisEqual来过滤掉重复值。但是，它似乎没有按预期工作。取下面的代码片段

import { isEqual } from 'lodash-es';

let cachedValue: any;

function testFn(observableVal: Observable<any>) {
  return observableVal
    .pipe(
      distinctUntilChanged(isEqual),
      tap(val => {
        const equal = isEqual(cachedValue, val);
        console.log('"output":', equal, cachedValue, val);
        cachedValue = val;
      })
    )
}

在这个例子中，我希望函数const equal内部tap永远不会=== true. 我希望这distinctUntilChanged(isEqual)会过滤掉任何值，其中isEqual(cachedValue, val) === true-->const equal === false总是意味着。但是，控制台输出显示：

"output": false undefined [ContactList]
"output": true [ContactList] [ContactList]
"output": true [ContactList] [ContactList]
"output": true [ContactList] [ContactList]

我是否误解了distinctUntilChanged()操作员如何工作的一些基本知识？我已经发布了一个简化的示例，因为实际的 rxjs 流非常复杂，但我不希望复杂性在操作员中const equal应该始终如此。=== falsetap

我只是想了解发生了什么，所以任何信息都值得赞赏。谢谢！

更新

需要注意的是，如果我将代码更改为：

"output": false undefined [ContactList]
"output": true [ContactList] [ContactList]
"output": true [ContactList] [ContactList]
"output": true [ContactList] [ContactList]

然后过滤按预期工作。我的印象distinctUntilChanged(isEqual)是相当于：

filter(val => {
  const equal = isEqual(cachedValue, val);
  cachedValue = val;
  return !equal;
})

我是否误会/误解了distinctUntilChanged运营商？

Answer 1

我想到了！感谢rxjs 问题中的评论：我不小心多次订阅了 observable（这不应该发生）。多个console.log实例来自不同的订阅实例。