javascript - RxJS 与最后一个比较并发出

标签 javascript reactive-programming rxjs

我对 ReactiveJS 比较陌生,我希望实现以下目标:

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

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

最佳答案

请阅读有关 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) {})

关于javascript - RxJS 与最后一个比较并发出,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34108730/

相关文章:

android - RxJava 运算符类似于 replay(1, 1, MINUTE),但在 1 分钟后重新订阅

redux - NGRX/Effects 将数据传递给 catchError

node.js - NestJS 返回 HTTP 请求的结果

javascript - 如何从 Observable<Array<any>> 中删除特定元素

javascript - onmouseout 没有触发,但 onmouseover 是

javascript - 从 Javascript 调用 SageMath 函数

javascript - 关于 Promise 异步 JavaScript 的问题

ios - 使用 RxSwift 和 RxCocoa 绑定(bind)模型并更新单元格

mongodb - 在 Mono 对象上执行 block() 时出现异常我从 ReactiveMongoRepository 对象返回

javascript - 在放置事件上启动 Bootstrap 模式