skipLastWithTime
运算符接受一个时间持续时间而不是项目数量。它会丢弃在源 Observable 的生命周期中的最后持续时间内发出的项目。您可以通过将毫秒数作为参数传递给 skipLastWithTime
来设置此持续时间。
请注意,这将延迟对源 Observable 的任何项目的发出,直到自发出后经过给定的持续时间。
skipLastWithTime
默认情况下针对 timeout
Scheduler 进行操作,但您也可以将您选择的 Scheduler 作为可选的第二个参数传递。
示例代码
var source = Rx.Observable.timer(0, 1000)
.take(10)
.skipLastWithTime(5000);
var subscription = source.subscribe(
function (x) { console.log('Next: ' + x); },
function (err) { console.log('Error: ' + err); },
function () { console.log('Completed'); });
Next: 0
Next: 1
Next: 2
Next: 3
Next: 4
Completed
skipLastWithTime
存在于以下每个发行版中
rx.all.js
rx.all.compat.js
rx.time.js
(需要 rx.js
或 rx.compat.js
)
rx.lite.js
rx.lite.compat.js