deka-dom-el/src/signals-lib/helpers.js

/**
 * Symbol used to identify signals in objects
 * @type {string}
 */
export const mark= "__dde_signal";

/**
 * Batches signal updates to improve performance
 * @type {Function}
 */
export const queueSignalWrite= (()=> {
	let pendingSignals= new Set();
	let scheduled= false;

	/**
	 * Processes all pending signal updates
	 * @private
	 */
	function flushSignals() {
		scheduled = false;
		for(const signal of pendingSignals){
			pendingSignals.delete(signal);
			const M = signal[mark];
			if(M) M.listeners.forEach(l => l(M.value));
		}
		pendingSignals.clear();
	}

	/**
	 * Queues a signal for update
	 * @param {Object} s - Signal to queue
	 */
	return function(s){
		pendingSignals.add(s);
		if(scheduled) return;
		scheduled = true;
		queueMicrotask(flushSignals);
	};
})();