import { Signal } from 'signal-polyfill';

// NOTE: this implementation *LEAKS*
//       because there is nothing to unwatch a computed.

let pending = false;
let watcher = new Signal.subtle.Watcher(() => {
  if (!pending) {
    pending = true;
    queueMicrotask(() => {
      pending = false;
      flushPending();
    });
  }
});
function flushPending() {
  for (const signal of watcher.getPending()) {
    signal.get();
  }

  // Keep watching... we don't know when we're allowed to stop watching
  watcher.watch();
}

/**
 * ⚠️ WARNING: Nothing unwatches ⚠️
 * This will produce a memory leak.
 */
function effect(cb) {
  let c = new Signal.Computed(() => cb());
  watcher.watch(c);
  c.get();
  return () => {
    watcher.unwatch(c);
  };
}

export { effect };
//# sourceMappingURL=microtask-effect.ts.js.map