refactor: rename internal signal modules

Author: brnrdog

packages/rescript-signals/src/signals/Signals__Computed.res

@@ -2,7 +2,7 @@ let makeWithoutEquals = (
   compute: unit => 'a,
   ~name: option<string>=?,
 ): Signals__Signal.t<'a> => {
-  let id = Id.make()
+  let id = Signals__Id.make()
   let equalsFn: ('a, 'a) => bool = (_a, _b) => false
 
   // Create a mutable ref to hold the signal so the compute function can update it
@@ -18,13 +18,13 @@ let makeWithoutEquals = (
   }
 
   // Create combined subs (this IS the observer for the computed)
-  let subs = Core.makeComputedSubs(recompute, ~deferEffectsUntilRecompute=false)
+  let subs = Signals__Core.makeComputedSubs(recompute, ~deferEffectsUntilRecompute=false)
 
   // Initial computation under tracking to establish dependencies
-  let prev = Scheduler.currentComputedSubs.contents
-  Scheduler.currentComputedSubs := Some(subs)
+  let prev = Signals__Scheduler.currentComputedSubs.contents
+  Signals__Scheduler.currentComputedSubs := Some(subs)
   let initialValue = compute()
-  Scheduler.currentComputedSubs := prev
+  Signals__Scheduler.currentComputedSubs := prev
 
   // Create the signal with the initial value
   let signal: Signals__Signal.t<'a> = {
@@ -37,8 +37,8 @@ let makeWithoutEquals = (
 
   // Set the ref so recompute can access the signal
   signalRef := signal
-  subs.lastGlobalVersion = Core.globalVersion.contents
-  Core.clearSubsDirty(subs)
+  subs.lastGlobalVersion = Signals__Core.globalVersion.contents
+  Signals__Core.clearSubsDirty(subs)
 
   signal
 }
@@ -48,7 +48,7 @@ let makeWithEquals = (
   equalsFn: ('a, 'a) => bool,
   ~name: option<string>=?,
 ): Signals__Signal.t<'a> => {
-  let id = Id.make()
+  let id = Signals__Id.make()
 
   // Create a mutable ref to hold the signal so the compute function can update it
   // Using Obj.magic to avoid Option wrapper overhead
@@ -71,13 +71,13 @@ let makeWithEquals = (
   }
 
   // Create combined subs (this IS the observer for the computed)
-  let subs = Core.makeComputedSubs(recompute, ~deferEffectsUntilRecompute=true)
+  let subs = Signals__Core.makeComputedSubs(recompute, ~deferEffectsUntilRecompute=true)
 
   // Initial computation under tracking to establish dependencies
-  let prev = Scheduler.currentComputedSubs.contents
-  Scheduler.currentComputedSubs := Some(subs)
+  let prev = Signals__Scheduler.currentComputedSubs.contents
+  Signals__Scheduler.currentComputedSubs := Some(subs)
   let initialValue = compute()
-  Scheduler.currentComputedSubs := prev
+  Signals__Scheduler.currentComputedSubs := prev
 
   // Create the signal with the initial value
   let signal: Signals__Signal.t<'a> = {
@@ -90,8 +90,8 @@ let makeWithEquals = (
 
   // Set the ref so recompute can access the signal
   signalRef := signal
-  subs.lastGlobalVersion = Core.globalVersion.contents
-  Core.clearSubsDirty(subs)
+  subs.lastGlobalVersion = Signals__Core.globalVersion.contents
+  Signals__Core.clearSubsDirty(subs)
 
   signal
 }
@@ -107,5 +107,5 @@ let make = (
   }
 
 let dispose = (signal: Signals__Signal.t<'a>): unit => {
-  Core.clearSubsDeps(signal.subs)
+  Signals__Core.clearSubsDeps(signal.subs)
 }

…es/rescript-signals/src/signals/Core.res …pt-signals/src/signals/Signals__Core.respackages/rescript-signals/src/signals/Core.res renamed to packages/rescript-signals/src/signals/Signals__Core.res packages/rescript-signals/src/signals/Core.res renamed to packages/rescript-signals/src/signals/Signals__Core.res

@@ -1,7 +1,7 @@
 type disposer = {dispose: unit => unit}
 
 let runWithDisposer = (fn: unit => option<unit => unit>, ~name: option<string>=?): disposer => {
-  let observerId = Id.make()
+  let observerId = Signals__Id.make()
   let cleanup: ref<option<unit => unit>> = ref(None)
 
   // Wrapper that handles cleanup
@@ -17,24 +17,24 @@ let runWithDisposer = (fn: unit => option<unit => unit>, ~name: option<string>=?
   }
 
   // Create observer using Core types
-  let observer = Core.makeObserver(observerId, #Effect, runWithCleanup, ~name?)
+  let observer = Signals__Core.makeObserver(observerId, #Effect, runWithCleanup, ~name?)
 
   // Initial run under tracking (no need to clearDeps - observer is fresh)
-  let prev = Scheduler.currentObserver.contents
-  Scheduler.currentObserver := Some(observer)
+  let prev = Signals__Scheduler.currentObserver.contents
+  Signals__Scheduler.currentObserver := Some(observer)
 
   try {
     observer.run()
-    Core.clearDirty(observer)
-    Scheduler.currentObserver := prev
+    Signals__Core.clearDirty(observer)
+    Signals__Scheduler.currentObserver := prev
   } catch {
   | exn =>
-    Scheduler.currentObserver := prev
+    Signals__Scheduler.currentObserver := prev
     throw(exn)
   }
 
   // Compute level
-  observer.level = Scheduler.computeLevel(observer)
+  observer.level = Signals__Scheduler.computeLevel(observer)
 
   // Return disposer - stores observer reference directly (no Map lookup needed)
   let disposed = ref(false)
@@ -49,7 +49,7 @@ let runWithDisposer = (fn: unit => option<unit => unit>, ~name: option<string>=?
       | None => ()
       }
 
-      Core.clearDeps(observer)
+      Signals__Core.clearDeps(observer)
     }
   }