Stream fix

2025-03-21 03:24:55 +01:00
parent aab83907ba
commit 2d94e84941
2 changed files with 8 additions and 6 deletions
--- a/packages/extension-lazyref/src/index.ts
+++ b/packages/extension-lazyref/src/index.ts
@@ -12,9 +12,10 @@ export const LazyRefExtension = ReffuseExtension.make(() => ({
        const initialState = this.useMemo(() => ref, [], { doNotReExecuteOnRuntimeOrContextChange: true })
        const [reactStateValue, setReactStateValue] = React.useState(initialState)

-        this.useFork(() => Stream.runForEach(ref.changes, v => Effect.sync(() =>
-            setReactStateValue(v)
-        )), [ref])
+        this.useFork(() => Stream.runForEach(
+            Stream.changes(ref.changes),
+            v => Effect.sync(() => setReactStateValue(v)),
+        ), [ref])

        const setValue = this.useCallbackSync((setStateAction: React.SetStateAction<A>) =>
            LazyRef.update(ref, prevState =>