Merge pull request #14 from efflore/bugfix/v0.8.2

slightly optimized scheduler

Author: estherbrunner

README.md

@@ -2,7 +2,7 @@
 
 UIElement - the "look ma, no JS framework!" library bringing signals-based reactivity to vanilla Web Components
 
-Version 0.8.1
+Version 0.8.2
 
 ## What is UIElement?
 

cause-effect.js

@@ -33,24 +33,6 @@ const scheduler = () => {
     const effectQueue = new Map();
     const cleanupQueue = new Map();
     let requestId;
-    const requestTick = () => {
-        if (requestId)
-            cancelAnimationFrame(requestId);
-        requestId = requestAnimationFrame(flush);
-    };
-    const enqueue = (element, prop, fn) => {
-        if (!effectQueue.has(element))
-            effectQueue.set(element, new Map());
-        const elEffects = effectQueue.get(element);
-        if (!elEffects.has(prop))
-            elEffects.set(prop, fn);
-        requestTick();
-    };
-    const cleanup = (effect, fn) => {
-        if (!cleanupQueue.has(effect))
-            cleanupQueue.set(effect, fn);
-        requestTick();
-    };
     const run = (fn, msg) => {
         try {
             fn();
@@ -70,8 +52,27 @@ const scheduler = () => {
             run(fn, 'Cleanup failed');
         cleanupQueue.clear();
     };
+    const requestTick = () => {
+        if (requestId)
+            cancelAnimationFrame(requestId);
+        requestId = requestAnimationFrame(flush);
+    };
+    const getEffectMap = (key) => {
+        if (!effectQueue.has(key))
+            effectQueue.set(key, new Map());
+        return effectQueue.get(key);
+    };
+    const addToQueue = (map) => (key, fn) => {
+        const more = !map.has(key);
+        map.set(key, fn);
+        if (more)
+            requestTick();
+    };
     queueMicrotask(flush); // initial flush when the call stack is empty
-    return { enqueue, cleanup };
+    return {
+        enqueue: (element, prop, fn) => addToQueue(getEffectMap(element))(prop, fn),
+        cleanup: addToQueue(cleanupQueue)
+    };
 };
 
 /* === Internal === */
@@ -174,8 +175,7 @@ const effect = (fn) => {
         activeEffect = n;
         const cleanupFn = fn((element, prop, callback) => {
             enqueue(element, prop, callback);
-            if (!targets.has(element))
-                targets.add(element);
+            targets.add(element);
         });
         if (isFunction(cleanupFn))
             cleanup(n, cleanupFn);

cause-effect.min.js

@@ -94,24 +94,6 @@ const scheduler = () => {
     const effectQueue = new Map();
     const cleanupQueue = new Map();
     let requestId;
-    const requestTick = () => {
-        if (requestId)
-            cancelAnimationFrame(requestId);
-        requestId = requestAnimationFrame(flush);
-    };
-    const enqueue = (element, prop, fn) => {
-        if (!effectQueue.has(element))
-            effectQueue.set(element, new Map());
-        const elEffects = effectQueue.get(element);
-        if (!elEffects.has(prop))
-            elEffects.set(prop, fn);
-        requestTick();
-    };
-    const cleanup = (effect, fn) => {
-        if (!cleanupQueue.has(effect))
-            cleanupQueue.set(effect, fn);
-        requestTick();
-    };
     const run = (fn, msg) => {
         try {
             fn();
@@ -131,8 +113,27 @@ const scheduler = () => {
             run(fn, 'Cleanup failed');
         cleanupQueue.clear();
     };
+    const requestTick = () => {
+        if (requestId)
+            cancelAnimationFrame(requestId);
+        requestId = requestAnimationFrame(flush);
+    };
+    const getEffectMap = (key) => {
+        if (!effectQueue.has(key))
+            effectQueue.set(key, new Map());
+        return effectQueue.get(key);
+    };
+    const addToQueue = (map) => (key, fn) => {
+        const more = !map.has(key);
+        map.set(key, fn);
+        if (more)
+            requestTick();
+    };
     queueMicrotask(flush); // initial flush when the call stack is empty
-    return { enqueue, cleanup };
+    return {
+        enqueue: (element, prop, fn) => addToQueue(getEffectMap(element))(prop, fn),
+        cleanup: addToQueue(cleanupQueue)
+    };
 };
 
 /* === Internal === */
@@ -204,8 +205,7 @@ const effect = (fn) => {
         activeEffect = n;
         const cleanupFn = fn((element, prop, callback) => {
             enqueue(element, prop, callback);
-            if (!targets.has(element))
-                targets.add(element);
+            targets.add(element);
         });
         if (isFunction(cleanupFn))
             cleanup(n, cleanupFn);

index.js

@@ -9,7 +9,7 @@ import { setAttribute, setProperty, setStyle, setText, toggleAttribute, toggleCl
 
 /**
  * @name UIElement
- * @version 0.8.1
+ * @version 0.8.2
  */
 
 export {

index.min.js

@@ -1,6 +1,6 @@
 {
   "name": "@efflore/ui-element",
-  "version": "0.8.1",
+  "version": "0.8.2",
   "description": "UIElement - minimal reactive framework based on Web Components",
   "main": "index.min.js",
   "types": "types/ui-element.d.ts",

index.ts

@@ -139,7 +139,7 @@ const effect = (fn: EffectCallback) => {
     activeEffect = n
     const cleanupFn = fn((element: Element, prop: string, callback: (element: Element) => () => void): void => {
       enqueue(element, prop, callback)
-      if (!targets.has(element)) targets.add(element)
+      targets.add(element)
     })
     if (isFunction(cleanupFn)) cleanup(n, cleanupFn)
     activeEffect = prev

package.json

@@ -1,30 +1,17 @@
-import type { Effect } from '../cause-effect';
 import { log, LOG_ERROR } from './log';
 
+/* === Types === */
+
+type UnknownFunction = (...args: unknown[]) => unknown
+type ElementFunction = (element: Element) => () => void
+
 /* === Exported Function === */
 
 const scheduler = () => {
   const effectQueue = new Map()
   const cleanupQueue = new Map()
   let requestId: number
 
-  const requestTick = () => {
-    if (requestId) cancelAnimationFrame(requestId)
-    requestId = requestAnimationFrame(flush)
-  }
-
-  const enqueue = (element: Element, prop: string, fn: (element: Element) => () => void) => {
-    if (!effectQueue.has(element)) effectQueue.set(element, new Map())
-    const elEffects = effectQueue.get(element)
-    if (!elEffects.has(prop)) elEffects.set(prop, fn)
-    requestTick()
-  }
-
-  const cleanup = (effect: Effect, fn: () => void) => {
-    if (!cleanupQueue.has(effect)) cleanupQueue.set(effect, fn)
-    requestTick()
-  }
-
   const run = (fn: () => void, msg: string) => {
     try {
       fn()
@@ -44,9 +31,30 @@ const scheduler = () => {
       run(fn, 'Cleanup failed')
     cleanupQueue.clear()
   }
+
+  const requestTick = () => {
+    if (requestId) cancelAnimationFrame(requestId)
+    requestId = requestAnimationFrame(flush)
+  }
+
+  const getEffectMap = (key: Element) => {
+    if (!effectQueue.has(key)) effectQueue.set(key, new Map())
+    return effectQueue.get(key)
+  }
+
+  const addToQueue = (map: Map<unknown, UnknownFunction>) =>
+    (key: unknown, fn: UnknownFunction) => {
+      const more = !map.has(key)
+      map.set(key, fn)
+      if (more) requestTick()
+    }
+
   queueMicrotask(flush) // initial flush when the call stack is empty
+  return {
+    enqueue: (element: Element, prop: string, fn: ElementFunction) => addToQueue(getEffectMap(element))(prop, fn),
+    cleanup: addToQueue(cleanupQueue)
+  }
 
-  return { enqueue, cleanup }
 }
 
 export default scheduler

src/cause-effect.ts

@@ -11,7 +11,7 @@ import { setText, setProperty, setAttribute, toggleAttribute, toggleClass, setSt
 
 /* === Types === */
 
-type AttributeParser = (<T>(value: string[], element: UIElement, old: string | undefined) => T[])
+type AttributeParser = (value: string[], element: UIElement, old: string | undefined) => unknown[]
 
 type AttributeMap = Record<string, AttributeParser>