RxJS 与 last 比较并发出

Question

我对 ReactiveJS 比较陌生，我想实现以下目标：

只有在时间戳（updated_at）与上一个不同时才发出一个值（对象）。

var checkJobsRx = new Rx.Subject();
checkJobsRx
.dosomethinghere()
.subscribe(function (data) {})

Answer 1

请阅读有关 distinctUntilChanged() 的文档。 http://reactivex.io/documentation/operators/distinct.html

我猜下面的代码就是问题的答案。（只添加了 1 行）

var checkJobsRx = new Rx.Subject();
  checkJobsRx
 .dosomethinghere()
 .distinctUntilChanged(function(job) { return job.updated_at })
 .subscribe(function (data) {})

Answer 2

您可以使用distinctUntilChanged 来检查发出的重复值：

checkJobsRx
  .map(fooBar)
  .distinctUntilChanged((item) => item.updated_at)
  .subscribe((data) => { })

查看the documentation