如何使用 RxJs distinctUntilChanged?
How to use RxJs distinctUntilChanged?
我开始使用 RxJs(使用 v5 beta),但不知何故我不知道如何使用 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 文档中的 links 似乎已失效
------编辑-----
一些额外的调试:
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 ]
这里是 sample 你的代码是 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)})
来跟踪每个函数的输出。我只能想到 of
运算符可能只传递数组的最后一个元素。
我得到了答案here。基本上,函数签名从 (key selector, comparator) 更改为 (comparator, key selector)。
v5 中的例子是这样的:
Observable.of(['a', 1], ['a', 1], ['a', 0], ['a', 1])
.distinctUntilChanged(null, x => x[1])
.subscribe(x => console.log(x))
我开始使用 RxJs(使用 v5 beta),但不知何故我不知道如何使用 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 文档中的 links 似乎已失效
------编辑-----
一些额外的调试:
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 ]
这里是 sample 你的代码是 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)})
来跟踪每个函数的输出。我只能想到 of
运算符可能只传递数组的最后一个元素。
我得到了答案here。基本上,函数签名从 (key selector, comparator) 更改为 (comparator, key selector)。
v5 中的例子是这样的:
Observable.of(['a', 1], ['a', 1], ['a', 0], ['a', 1])
.distinctUntilChanged(null, x => x[1])
.subscribe(x => console.log(x))