run-at-intervals.js

/* use sleep from below, or bring your own */
// export const sleep = millis => new Promise(_ => setTimeout(_, millis));

async function impl(sentinel, func, interval, args) {
  for (; !sentinel.aborted; await sleep(interval)) {
    await func(...args);
  }
}

export default function runAtIntervals(func, interval, ...args) {
  const sentinel = { aborted: false };
  const promise = impl(sentinel, func, interval, args);
  return {
    abort() {
      sentinel.aborted = true;
    },
    catch: onRejected => promise.catch(onRejected);
  };
}