Sha256: 1adaa032e3b4780d440374b29b908863995d6394f37e722b770d51687d541594
Contents?: true
Size: 477 Bytes
Versions: 14
Compression:
Stored size: 477 Bytes
Contents
function observableTimerDateAndPeriod(dueTime, period, scheduler) {
return new AnonymousObservable(function (observer) {
var d = dueTime, p = normalizeTime(period);
return scheduler.scheduleRecursiveWithAbsoluteAndState(0, d, function (count, self) {
if (p > 0) {
var now = scheduler.now();
d = d + p;
d <= now && (d = now + p);
}
observer.onNext(count);
self(count + 1, d);
});
});
}
Version data entries
14 entries across 7 versions & 1 rubygems