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

@reffuse/extension-query 0.1.5 #16

Merged
Thilawyn merged 347 commits from next into master 2025-06-01 05:28:47 +02:00
Conversation 0 Commits 347 Files Changed 10 +15 -62
2 changed files with 15 additions and 62 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 65810a6d79 - Show all commits

5
packages/example/src/routes/promise.tsx
View File

@@ -15,9 +15,8 @@ const Result = Schema.Tuple(Schema.String)
type Result = typeof Result.Type
function RouteComponent() {
const promise = R.usePromiseScoped(Effect.addFinalizer(() => Console.log("Cleanup")).pipe(
Effect.andThen(HttpClient.HttpClient),
Effect.flatMap(client => client.get("https://www.uuidtools.com/api/generate/v4")),
const promise = R.usePromise(Effect.addFinalizer(() => Console.log("Cleanup")).pipe(
Effect.andThen(HttpClient.get("https://www.uuidtools.com/api/generate/v4")),
HttpClient.withTracerPropagation(false),
Effect.flatMap(res => res.json),
Effect.flatMap(Schema.decodeUnknown(Result)),

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

@@ -284,19 +284,6 @@ export class Reffuse<R> {
}
usePromise<A, E>(
effect: Effect.Effect<A, E, R>,
deps?: React.DependencyList,
options?: { readonly signal?: AbortSignal } & RenderOptions,
): Promise<A> {
const runPromise = this.useRunPromise()
return React.useMemo(() => runPromise(effect, options), [
...options?.doNotReExecuteOnRuntimeOrContextChange ? [] : [runPromise],
...(deps ?? []),
])
}
usePromiseScoped<A, E>(
effect: Effect.Effect<A, E, R | Scope.Scope>,
deps?: React.DependencyList,
options?: { readonly signal?: AbortSignal } & Runtime.RunForkOptions & RenderOptions & ScopeOptions,
@@ -310,27 +297,29 @@ export class Reffuse<R> {
const { promise, resolve, reject } = Promise.withResolvers<A>()
setValue(promise)
const scope = runSync(Scope.make(options?.finalizerExecutionStrategy))
const scope = runSync(options?.scope
? Scope.fork(options.scope, options?.finalizerExecutionStrategy ?? ExecutionStrategy.sequential)
: Scope.make(options?.finalizerExecutionStrategy)
)
const fiber = effect.pipe(
const cleanup = () => { runFork(Scope.close(scope, Exit.void)) }
if (options?.signal)
options.signal.addEventListener("abort", cleanup)
effect.pipe(
Effect.provideService(Scope.Scope, scope),
Effect.match({
onSuccess: resolve,
onFailure: reject,
}),
// TODO: use scope from RunForkOptions?
effect => runFork(effect, { ...options, scope }),
)
return () => {
// Fiber.interrupt(fiber).pipe(
// Effect.andThen(Scope.close(scope, Exit.void)),
// // \/ TODO: should interrupted promises reject?
// // Effect.andThen(Effect.sync(() => { reject() })),
// runFork,
// )
runFork(Scope.close(scope, Exit.void))
if (options?.signal)
options.signal.removeEventListener("abort", cleanup)
cleanup()
}
}, [
...options?.doNotReExecuteOnRuntimeOrContextChange ? [] : [runSync, runFork],
@@ -340,41 +329,6 @@ export class Reffuse<R> {
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(