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)),