diff --git a/packages/rx/src/internal/registry.ts b/packages/rx/src/internal/registry.ts index 1218f26..8b108d1 100644 --- 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) {