simplify subscribe immediate

tim-smart · Sep 19, 2023 · d790ad1 · d790ad1
1 parent 1b37a51
commit d790ad1
Showing 1 changed file with 3 additions and 9 deletions.
diff --git a/packages/rx/src/internal/registry.ts b/packages/rx/src/internal/registry.ts
@@ -39,18 +39,12 @@ class RegistryImpl implements Registry.Registry {
 
   subscribe: Rx.Rx.Subscribe = (rx, f, options) => {
     const node = this.ensureNode(rx)
+    if (options?.immediate) {
+      f(node.value())
+    }
     const remove = node.subscribe(function() {
       f(node._value)
     })
-
-    if (options?.immediate) {
-      if ((node.state & NodeFlags.initialized) === 0) {
-        node.value()
-      } else {
-        f(node.value())
-      }
-    }
-
     return () => {
       remove()
       if (node.canBeRemoved) {