reduce the code little bit

Author: kethan

lite/index.js

@@ -1,19 +1,19 @@
 const
     // FinalizationRegistry to clean up subscriptions when objects are garbage collected
-    registry = new FinalizationRegistry(unsub => (unsub && unsub?.call?.())),
+    registry = new FinalizationRegistry(unsub => unsub?.call()),
 
     // API object providing basic functions for handling effects and values
     api = {
         // Handle any reactive subscription
-        any: undefined,
-        // If any cleanup is requested
-        cleanup: undefined,
+        // any: undefined,
+        // // If any cleanup is requested
+        // cleanup: undefined,
         // Executes the provided function
-        effect: (f) => f(),
+        effect: f => f(),
         // Returns false for any value (placeholder implementation)
-        is: (v) => v?.call,
+        is: v => v?.call,
         // Retrieves the value (returns it as is)
-        get: (v) => v?.call(),
+        get: v => v?.call(),
     },
 
     // Utility function to handle and unwrap values of signals, observable, etc especially functions
@@ -26,10 +26,10 @@ const
         api.is(arg) ||                   // Custom observable check
         arg.call                         // Function
     ),
-    
+
     // Subscribe to an observable or value, and provide a callback for each value
     sub = (target, stop, unsub) => (next, error, cleanup) => target && (
-        unsub = ((!api?.any && (api.is(target) || target?.call)) && api.effect(() => (next(get(target)), api?.cleanup?.(cleanup), cleanup))) ||
+        unsub = ((!api.any && (api.is(target) || target.call)) && api.effect(() => (next(get(target)), api.cleanup?.(cleanup), cleanup))) ||
         (
             target.then?.(v => (!stop && next(get(v)), cleanup?.()), error) ||
             target[Symbol.asyncIterator] && (async v => {
@@ -40,7 +40,7 @@ const
                 } catch (err) { error?.(err) }
             })()
         ) && (_ => stop = 1) ||
-        (api?.any?.(target)?.(next, error, cleanup)),
+        (api.any?.(target)?.(next, error, cleanup)),
         // register autocleanup
         registry.register(target, unsub),
         unsub

package.json

@@ -1,7 +1,7 @@
 {
 	"name": "usub",
 	"description": "Subscribe to any reactive sources",
-	"version": "0.5.0",
+	"version": "0.5.1",
 	"type": "module",
 	"source": "./src/index.js",
 	"main": "./dist/index.js",

src/index.js

@@ -13,9 +13,9 @@ const
     // API object providing basic functions for handling effects and values
     api = {
         // Handle any reactive subscription
-        any: undefined,
-        // If any cleanup is requested
-        cleanup: undefined,
+        // any: undefined,
+        // // If any cleanup is requested
+        // cleanup: undefined,
         // Executes the provided function
         effect: (f) => f(),
         // Returns false for any value (placeholder implementation)
@@ -41,7 +41,7 @@ const
     sub = (target, stop, unsub) => (next, error, cleanup) => target && (
         unsub = unsubr((target[Symbol.observable]?.() || target).subscribe?.((v) => next(get(v)), error, cleanup), cleanup) ||
         target.set && target.call?.(stop, next) ||
-        ((!api?.any && (api.is(target) || target?.call)) && api.effect(() => (next(get(target)), api?.cleanup?.(cleanup), cleanup))) ||
+        ((!api.any && (api.is(target) || target.call)) && api.effect(() => (next(get(target)), api.cleanup?.(cleanup), cleanup))) ||
         (
             target.then?.(v => (!stop && next(get(v)), cleanup?.()), error) ||
             target[Symbol.asyncIterator] && (async v => {
@@ -52,7 +52,7 @@ const
                 } catch (err) { error?.(err) }
             })()
         ) && (_ => stop = 1) ||
-        (api?.any?.(target)?.(next, error, cleanup)),
+        (api.any?.(target)?.(next, error, cleanup)),
         // register autocleanup
         registry.register(target, unsub),
         unsub