From 3b90384f8f25bb97ca112059287079ea49787f4e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Julien=20Valverd=C3=A9?= Date: Fri, 14 Nov 2025 02:56:05 +0100 Subject: [PATCH] Refactor --- packages/effect-fc/src/Stream.ts | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/packages/effect-fc/src/Stream.ts b/packages/effect-fc/src/Stream.ts index 726b7be..71cba72 100644 --- a/packages/effect-fc/src/Stream.ts +++ b/packages/effect-fc/src/Stream.ts @@ -30,11 +30,9 @@ export const useStream: { return reactStateValue as Option.Some }) -export const useStreamFromReactiveValues: { - ( - values: A - ): Effect.Effect, never, Scope.Scope> -} = Effect.fnUntraced(function* (values: A) { +export const useStreamFromReactiveValues = Effect.fnUntraced(function* ( + values: A +): Effect.fn.Return, never, Scope.Scope> { const { latest, pubsub, stream } = yield* Component.useOnMount(() => Effect.Do.pipe( Effect.bind("latest", () => Ref.make(values)), Effect.bind("pubsub", () => Effect.acquireRelease(PubSub.unbounded(), PubSub.shutdown)),