Thilawyn/reffuse
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

usePromiseScoped fork implementation
All checks were successful
Lint / lint (push) Successful in 10s
Details

Browse Source
This commit is contained in:
Julien Valverdé
2025-02-18 23:47:32 +01:00
parent 809f512d11
commit 6c843562ab
1 changed files with 57 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
packages/reffuse/src/Reffuse.ts
View File

@@ -301,38 +301,80 @@ export class Reffuse<R> {
usePromiseScoped<A, E>(
effect: Effect.Effect<A, E, R | Scope.Scope>,
deps?: React.DependencyList,
options?: { readonly signal?: AbortSignal } & RenderOptions & ScopeOptions,
options?: { readonly signal?: AbortSignal } & Runtime.RunForkOptions & RenderOptions & ScopeOptions,
): Promise<A> {
const runSync = this.useRunSync()
const runPromise = this.useRunPromise()
const runFork = this.useRunFork()
const [value, setValue] = React.useState(new Promise<A>(() => {}))
const [value, setValue] = React.useState(Promise.withResolvers<A>().promise)
React.useEffect(() => {
const controller = new AbortController()
const signal = AbortSignal.any([
controller.signal,
...options?.signal ? [options.signal] : [],
])
const { promise, resolve, reject } = Promise.withResolvers<A>()
setValue(promise)
const scope = runSync(Scope.make(options?.finalizerExecutionStrategy))
setValue(runPromise(Effect.provideService(effect, Scope.Scope, scope), {
...options,
signal,
}))
const fiber = effect.pipe(
Effect.provideService(Scope.Scope, scope),
Effect.match({
onSuccess: resolve,
onFailure: reject,
}),
// TODO: use scope from RunForkOptions?
effect => runFork(effect, options),
)
return () => {
controller.abort()
runSync(Scope.close(scope, Exit.void))
Fiber.interrupt(fiber).pipe(
Effect.andThen(Scope.close(scope, Exit.void)),
Effect.andThen(Effect.sync(() => { reject() })), // TODO: Relevant?
runFork,
)
}
}, [
...options?.doNotReExecuteOnRuntimeOrContextChange ? [] : [runSync, runPromise],
...options?.doNotReExecuteOnRuntimeOrContextChange ? [] : [runSync, runFork],
...(deps ?? []),
])
return value
}
// usePromiseScoped<A, E>(
// effect: Effect.Effect<A, E, R | Scope.Scope>,
// deps?: React.DependencyList,
// options?: { readonly signal?: AbortSignal } & RenderOptions & ScopeOptions,
// ): Promise<A> {
// const runSync = this.useRunSync()
// const runPromise = this.useRunPromise()
// const [value, setValue] = React.useState(new Promise<A>(() => {}))
// React.useEffect(() => {
// const controller = new AbortController()
// const signal = AbortSignal.any([
// controller.signal,
// ...options?.signal ? [options.signal] : [],
// ])
// const scope = runSync(Scope.make(options?.finalizerExecutionStrategy))
// setValue(runPromise(Effect.provideService(effect, Scope.Scope, scope), {
// ...options,
// signal,
// }))
// return () => {
// controller.abort()
// runSync(Scope.close(scope, Exit.void))
// }
// }, [
// ...options?.doNotReExecuteOnRuntimeOrContextChange ? [] : [runSync, runPromise],
// ...(deps ?? []),
// ])
// return value
// }
useRef<A>(value: A): SubscriptionRef.SubscriptionRef<A> {
return this.useMemo(