From 2d94e849410da27266e049e84afe785987b9c172 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Julien=20Valverd=C3=A9?= Date: Fri, 21 Mar 2025 03:24:55 +0100 Subject: [PATCH] Stream fix --- packages/extension-lazyref/src/index.ts | 7 ++++--- packages/reffuse/src/ReffuseHelpers.ts | 7 ++++--- 2 files changed, 8 insertions(+), 6 deletions(-) diff --git a/packages/extension-lazyref/src/index.ts b/packages/extension-lazyref/src/index.ts index 18e6aef..343ecdf 100644 --- 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) => LazyRef.update(ref, prevState => diff --git a/packages/reffuse/src/ReffuseHelpers.ts b/packages/reffuse/src/ReffuseHelpers.ts index 2f4f449..60ce35d 100644 --- a/packages/reffuse/src/ReffuseHelpers.ts +++ b/packages/reffuse/src/ReffuseHelpers.ts @@ -395,9 +395,10 @@ export abstract class ReffuseHelpers { 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) => Ref.update(ref, prevState =>