An Effection operation that takes any operation and runs it periodically on a heart beat

heartbeat.ts

import { action, spawn, sleep, type Operation } from "effection";

export function* heartbeat(duration: number, op: () => Operation<unknown>): Operation<void> {
  while (true) {
    // this action captures a return point.
    yield* action(function* (restart) {

      // wait for the duration and return to the next loop iteration
      yield* spawn(function*() {
        yield* sleep(duration);
        restart();
      });

      // run the operation. If the heartbeat is exceeded, it will be cancelled
      yield* op();
    });
  }
}