sync 1.0.6

Author: johnsoncodehk

packages/reactivity/src/system.ts

@@ -1,5 +1,5 @@
 /* eslint-disable */
-// Ported from https://github.com/stackblitz/alien-signals/blob/v1.0.5/src/system.ts
+// Ported from https://github.com/stackblitz/alien-signals/blob/v1.0.6/src/system.ts
 import type { ComputedRefImpl as Computed } from './computed.js'
 import type { ReactiveEffect as Effect } from './effect.js'
 
@@ -32,9 +32,14 @@ export const enum SubscriberFlags {
   Propagated = Dirty | PendingComputed,
 }
 
-let batchDepth = 0
+interface QueuedLink {
+  effect: Effect
+  next: QueuedLink | undefined
+}
 
-const queuedEffects: Effect[] = []
+let batchDepth = 0
+let queuedEffects: QueuedLink | undefined
+let queuedEffectsTail: QueuedLink | undefined
 
 export function startBatch(): void {
   ++batchDepth
@@ -107,7 +112,17 @@ export function propagate(link: Link): void {
         continue
       }
       if (subFlags & SubscriberFlags.Effect) {
-        queuedEffects.push(sub as Effect)
+        if (queuedEffectsTail !== undefined) {
+          queuedEffectsTail = queuedEffectsTail.next = {
+            effect: sub as Effect,
+            next: undefined,
+          }
+        } else {
+          queuedEffectsTail = queuedEffects = {
+            effect: sub as Effect,
+            next: undefined,
+          }
+        }
       }
     } else if (!(subFlags & (SubscriberFlags.Tracking | targetFlag))) {
       sub.flags = subFlags | targetFlag
@@ -205,8 +220,13 @@ export function processComputedUpdate(
 }
 
 export function processEffectNotifications(): void {
-  while (queuedEffects.length) {
-    queuedEffects.shift()!.notify()
+  while (queuedEffects !== undefined) {
+    const effect = queuedEffects.effect
+    queuedEffects = queuedEffects.next
+    if (queuedEffects === undefined) {
+      queuedEffectsTail = undefined
+    }
+    effect.notify()
   }
 }