Sha256: 75326db52a329333f78aabbf712a1c2aea86c8c3e3ed93c5a8af8a60b79bc914
Contents?: true
Size: 477 Bytes
Versions: 14
Compression:
Stored size: 477 Bytes
Contents
function observableTimerTimeSpanAndPeriod(dueTime, period, scheduler) {
return dueTime === period ?
new AnonymousObservable(function (observer) {
return scheduler.schedulePeriodicWithState(0, period, function (count) {
observer.onNext(count);
return count + 1;
});
}) :
observableDefer(function () {
return observableTimerDateAndPeriod(scheduler.now() + dueTime, period, scheduler);
});
}
Version data entries
14 entries across 7 versions & 1 rubygems