timeInterval 运算符将一个源 Observable 转换为一个 Observable,它发射关于源 Observable 的连续发射之间经过的时间间隔的指示。这个新的 Observable 的第一个发射指示从观察者订阅 Observable 的时间到源 Observable 发射第一个项目的时间之间经过的时间间隔。没有相应的发射来标记源 Observable 的最后一个发射和随后的对 onCompleted
的调用之间经过的时间间隔。
var source = Rx.Observable.timer(0, 1000)
.timeInterval()
.map(function (x) { return x.value + ':' + x.interval; })
.take(5);
var subscription = source.subscribe(
function (x) { console.log('Next: ' + x); },
function (err) { console.log('Error: ' + err); },
function () { console.log('Completed'); });