expose registry dispose & reset

tim-smart · Feb 5, 2024 · bd7f6ba · bd7f6ba
1 parent fe01025
commit bd7f6ba
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 3 deletions.
diff --git a/.changeset/friendly-zoos-fix.md b/.changeset/friendly-zoos-fix.md
@@ -0,0 +1,5 @@
+---
+"@effect-rx/rx": patch
+---
+
+expose registry dispose & reset
diff --git a/packages/rx/src/Registry.ts b/packages/rx/src/Registry.ts
@@ -27,6 +27,8 @@ export interface Registry {
   readonly refresh: Rx.Rx.RefreshRxSync
   readonly set: Rx.Rx.Set
   readonly subscribe: Rx.Rx.Subscribe
+  readonly reset: () => void
+  readonly dispose: () => void
 }
 
 /**

diff --git a/packages/rx/src/internal/registry.ts b/packages/rx/src/internal/registry.ts
@@ -180,16 +180,19 @@ class RegistryImpl implements Registry.Registry {
     })
   }
 
-  dispose(): void {
-    this.disposed = true
-
+  reset(): void {
     this.timeoutBuckets.forEach(([, handle]) => clearTimeout(handle))
     this.timeoutBuckets.clear()
     this.nodeTimeoutBucket.clear()
 
     this.nodes.forEach((node) => node.remove())
     this.nodes.clear()
   }
+
+  dispose(): void {
+    this.disposed = true
+    this.reset()
+  }
 }
 
 const enum NodeFlags {