Update deps, add additional unit tests, add signals-polyfill and signia, update results

src/cellxBench.ts

@@ -95,14 +95,17 @@ export const cellxbench = (framework: ReactiveFramework) => {
       [-3, -6, -2, 2],
       [-2, -4, 2, 3],
     ],
-    2500: [
-      [-3, -6, -2, 2],
-      [-2, -4, 2, 3],
-    ],
-    5000: [
-      [2, 4, -1, -6],
-      [-2, 1, -4, -4],
-    ],
+    // TODO: https://github.com/milomg/js-reactivity-benchmark/pull/13#issuecomment-2395253701
+    // @see https://github.com/mobxjs/mobx/issues/3926
+    // @see https://github.com/sveltejs/svelte/discussions/13277
+    // 2500: [
+    //   [-3, -6, -2, 2],
+    //   [-2, -4, 2, 3],
+    // ],
+    // 5000: [
+    //   [2, 4, -1, -6],
+    //   [-2, 1, -4, -4],
+    // ],
   };
 
   const results: Record<number, BenchmarkResults> = {};

src/dynamicBench.ts

@@ -10,7 +10,7 @@ import { fastestTest } from "./util/benchRepeat";
  */
 export async function dynamicBench(
   frameworkTest: FrameworkInfo,
-  testRepeats = 1
+  testRepeats = 5
 ): Promise<void> {
   const { framework } = frameworkTest;
   for (const config of perfTests) {

src/index.ts

@@ -1,5 +1,5 @@
 import { dynamicBench } from "./dynamicBench";
-// import { cellxbench } from "./cellxBench";
+import { cellxbench } from "./cellxBench";
 import { sbench } from "./sBench";
 import { frameworkInfo } from "./config";
 import { logPerfResult, perfReportHeaders } from "./util/perfLogging";
@@ -8,7 +8,6 @@ import { kairoBench } from "./kairoBench";
 
 async function main() {
   logPerfResult(perfReportHeaders());
-  (globalThis as any).__DEV__ = true;
 
   for (const frameworkTest of frameworkInfo) {
     const { framework } = frameworkTest;
@@ -17,10 +16,7 @@ async function main() {
     await molBench(framework);
     sbench(framework);
 
-    // MobX, Valtio, and Svelte fail this test currently, so disabling it for now.
-    // @see https://github.com/mobxjs/mobx/issues/3926
-    // @see https://github.com/sveltejs/svelte/discussions/13277
-    // cellxbench(framework);
+    cellxbench(framework);
 
     await dynamicBench(frameworkTest);
 

src/kairo/broad.ts

@@ -24,14 +24,14 @@ export function broadPropagation(bridge: ReactiveFramework) {
     bridge.withBatch(() => {
       head.write(1);
     });
-    // const atleast = 50 * 50;
+    const atleast = 50 * 50;
     callCounter.count = 0;
     for (let i = 0; i < 50; i++) {
       bridge.withBatch(() => {
         head.write(i);
       });
       console.assert(last.read() === i + 50);
     }
-    // console.assert(callCounter.count === atleast, callCounter.count);
+    console.assert(callCounter.count === atleast, callCounter.count);
   };
 }

src/kairo/deep.ts

@@ -25,7 +25,7 @@ export function deepPropagation(bridge: ReactiveFramework) {
     bridge.withBatch(() => {
       head.write(1);
     });
-    // const atleast = iter;
+    const atleast = iter;
     callCounter.count = 0;
     for (let i = 0; i < iter; i++) {
       bridge.withBatch(() => {
@@ -34,6 +34,6 @@ export function deepPropagation(bridge: ReactiveFramework) {
       console.assert(current.read() === len + i);
     }
 
-    // console.assert(callCounter.count === atleast);
+    console.assert(callCounter.count === atleast);
   };
 }

src/kairo/diamond.ts

@@ -27,14 +27,14 @@ export function diamond(bridge: ReactiveFramework) {
       head.write(1);
     });
     console.assert(sum.read() === 2 * width);
-    // const atleast = 500;
+    const atleast = 500;
     callCounter.count = 0;
     for (let i = 0; i < 500; i++) {
       bridge.withBatch(() => {
         head.write(i);
       });
       console.assert(sum.read() === (i + 1) * width);
     }
-    // console.assert(callCounter.count === atleast);
+    console.assert(callCounter.count === atleast);
   };
 }

src/kairo/repeated.ts

@@ -26,14 +26,14 @@ export function repeatedObservers(bridge: ReactiveFramework) {
       head.write(1);
     });
     console.assert(current.read() === size);
-    // const atleast = 100;
+    const atleast = 100;
     callCounter.count = 0;
     for (let i = 0; i < 100; i++) {
       bridge.withBatch(() => {
         head.write(i);
       });
       console.assert(current.read() === i * size);
     }
-    // console.assert(callCounter.count === atleast);
+    console.assert(callCounter.count === atleast);
   };
 }

src/kairo/triangle.ts

@@ -30,15 +30,15 @@ export function triangle(bridge: ReactiveFramework) {
       head.write(1);
     });
     console.assert(sum.read() === constant);
-    // const atleast = 100;
+    const atleast = 100;
     callCounter.count = 0;
     for (let i = 0; i < 100; i++) {
       bridge.withBatch(() => {
         head.write(i);
       });
       console.assert(sum.read() === constant - width + i * width);
     }
-    // console.assert(callCounter.count === atleast);
+    console.assert(callCounter.count === atleast);
   };
 }
 

src/kairo/unstable.ts

@@ -24,14 +24,15 @@ export function unstable(bridge: ReactiveFramework) {
       head.write(1);
     });
     console.assert(current.read() === 40);
-    // const atleast = 100;
+    const atleast = 100;
     callCounter.count = 0;
     for (let i = 0; i < 100; i++) {
       bridge.withBatch(() => {
         head.write(i);
       });
+      // TODO: this assertion is failing for Preact Signals (and possibly other frameworks)
       // console.assert(current.read() === i % 2 ? i * 2 * 10 : i * -10);
     }
-    // console.assert(callCounter.count === atleast);
+    console.assert(callCounter.count === atleast);
   };
 }