25

我开始使用 RxJs（使用 v5 测试版），但不知何故我无法弄清楚如何使用distinctUntilChanged. 如果我在 babel-node 中运行它，下面代码的输出是

[ 'a', 1 ]
{ key: 'a', state: 1 }
Next:  { value: 42 }
Completed

这不是我所期望的。为什么只有一个条目通过distinctUntilChanged？我希望输出是

[ 'a', 1 ]
[ 'a', 0 ]
[ 'a', 1 ]
{ key: 'a', state: 1 }
{ key: 'a', state: 2 }
{ key: 'a', state: 0 }
{ key: 'a', state: 1 }
Next:  { value: 42 }
Next:  { value: 24 }
Completed

这是代码

import {Observable} from 'rxjs'

Observable.of(['a', 1], ['a', 1], ['a', 0], ['a', 1])
  .distinctUntilChanged(x => x[1])
  .subscribe(x => console.log(x))

Observable.of({key: 'a', state: 1}, {key: 'a', state: 2}, {key: 'a', state: 0}, {key: 'a', state: 1})
  .distinctUntilChanged(x => x.state)
  .subscribe(x => console.log(x))

Observable.of({value: 42}, {value: 42}, {value: 24}, {value: 24})
  .distinctUntilChanged(x => x.value)
  .subscribe(
    function (x) {
      console.log('Next: ', x)
    },
    function (err) {
      console.log('Error: ' + err)
    },
    function () {
      console.log('Completed')
    }
  )

这些函数的 v5 文档中的链接似乎已失效

- - - 编辑 - - -

一些额外的调试：

Observable.of(['a', 1], ['a', 1], ['a', 0], ['a', 1])
  .do(x => console.log('before', x))
  .distinctUntilChanged(x => x[1])
  .do(x => console.log('after', x))
  .subscribe(x => console.log(x))

输出：

before [ 'a', 1 ]
after [ 'a', 1 ]
[ 'a', 1 ]
before [ 'a', 1 ]
before [ 'a', 0 ]
before [ 'a', 1 ]
4

2 回答 2

36

我在这里得到了答案。基本上，函数签名从（键选择器，比较器）更改为（比较器，键选择器）。

这就是示例在 v5 中的完成方式：

Observable.of(['a', 1], ['a', 1], ['a', 0], ['a', 1])
  .distinctUntilChanged(null, x => x[1])
  .subscribe(x => console.log(x))
于 2016-03-30T18:28:27.447 回答
2

这是一个示例，您的代码是 Rxjs V4。你会看到它工作正常。

Observable.of(['a', 1], ['a', 1], ['a', 0], ['a', 1])
  .distinctUntilChanged(x => x[1])
  .subscribe(x => console.log(x))
...

所以这似乎与新的测试版有关。这是distinctUntilChanged的​​规格。操作员本身似乎在版本 4 中工作。

为了进行测试，我建议您通过.do(function(x){console.log(x)})在运算符之间插入 a 来跟踪每个函数的输出。我只能想到of运算符可能只传递数组的最后一个元素。

于 2016-03-28T22:30:23.077 回答