Thilawyn/effect-fc
1
0
Fork 0
Code Issues 1 Pull Requests 1 Actions Packages Projects Releases Wiki Activity

0.2.1 #26

Merged
Thilawyn merged 144 commits from next into master 2025-12-01 23:37:40 +01:00
Conversation 0 Commits 144 Files Changed 27 +3 -5
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 3b90384f8f - Show all commits

6
packages/effect-fc/src/Stream.ts
View File

@@ -30,11 +30,9 @@ export const useStream: {
return reactStateValue as Option.Some<A> return reactStateValue as Option.Some<A>
}) })
export const useStreamFromReactiveValues: { export const useStreamFromReactiveValues = Effect.fnUntraced(function* <const A extends React.DependencyList>(
<const A extends React.DependencyList>(
values: A values: A
): Effect.Effect<Stream.Stream<A>, never, Scope.Scope> ): Effect.fn.Return<Stream.Stream<A>, never, Scope.Scope> {
} = Effect.fnUntraced(function* <const A extends React.DependencyList>(values: A) {
const { latest, pubsub, stream } = yield* Component.useOnMount(() => Effect.Do.pipe( const { latest, pubsub, stream } = yield* Component.useOnMount(() => Effect.Do.pipe(
Effect.bind("latest", () => Ref.make(values)), Effect.bind("latest", () => Ref.make(values)),
Effect.bind("pubsub", () => Effect.acquireRelease(PubSub.unbounded<A>(), PubSub.shutdown)), Effect.bind("pubsub", () => Effect.acquireRelease(PubSub.unbounded<A>(), PubSub.shutdown)),