Skip to content

Commit 659c30a

Browse files
committed
remove arg.call from is
1 parent 662099c commit 659c30a

File tree

2 files changed

+2
-5
lines changed

2 files changed

+2
-5
lines changed

package.json

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
{
22
"name": "usub",
33
"description": "Subscribe to any reactive sources",
4-
"version": "0.0.6",
4+
"version": "0.0.7",
55
"type": "module",
66
"source": "./src/index.js",
77
"main": "./dist/index.js",

src/index.js

+1-4
Original file line numberDiff line numberDiff line change
@@ -17,10 +17,8 @@ const
1717
api = {
1818
// Executes the provided function
1919
effect: (f) => f(),
20-
2120
// Returns false for any value (placeholder implementation)
2221
is: (v) => false,
23-
2422
// Retrieves the value (returns it as is)
2523
get: (v) => v,
2624
},
@@ -32,14 +30,13 @@ const
3230
is = (arg) => arg && !!(
3331
arg[Symbol.observable] || // Observable symbol
3432
arg[Symbol.asyncIterator] || // Async iterator
35-
arg?.call || // Function with call method
3633
arg.then || // Promise
3734
arg.subscribe || // Observable with subscribe method
3835
api.is(arg) // Custom observable check
3936
),
4037

4138
sub = (target, stop, unsub) => (next, error, complete) => target && (
42-
unsub = unsubr((target[Symbol.observable]?.() || target).subscribe?.(next, error, complete), complete) ||
39+
unsub = unsubr((target[Symbol.observable]?.() || target).subscribe?.((v) => next(get(v)), error, complete), complete) ||
4340
(target.call && !api.is(target) && api.effect(() => next(get(target)))) ||
4441
(api.is(target) && api.effect(() => next(get(target)))) ||
4542
(target.then?.(v => (!stop && next(get(v)), complete?.()), error)) ||

0 commit comments

Comments
 (0)