From d790ad15adf18b19db31eb5dcba805814811bc93 Mon Sep 17 00:00:00 2001 From: Tim Smart Date: Tue, 19 Sep 2023 20:14:23 +1200 Subject: [PATCH] simplify subscribe immediate --- packages/rx/src/internal/registry.ts | 12 +++--------- 1 file changed, 3 insertions(+), 9 deletions(-) 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) {