Fix

2026-07-23 03:22:16 +02:00
parent 7e816d041e
commit cce0a47ea5
1 changed files with 3 additions and 4 deletions
@@ -44,10 +44,9 @@ export class ScopeRegistryServiceImpl implements ScopeRegistryService {
        options: ScopeRegistryService.RegisterOptions,
    ): Effect.Effect<ScopeRegistryService.Entry> {
        return Effect.gen({ self: this }, function*() {
-            const now = yield* DateTime.now
            const entry = Equal.byReference({
                scope: yield* Scope.make(options.finalizerExecutionStrategy),
-                expiresAt: Option.some(DateTime.addDuration(now, options.finalizerExecutionDebounce)),
+                expiresAt: Option.some(DateTime.addDuration(yield* DateTime.now, options.finalizerExecutionDebounce)),
                finalizerExecutionDebounce: options.finalizerExecutionDebounce,
            })

@@ -115,12 +114,12 @@ export class ScopeRegistryServiceImpl implements ScopeRegistryService {
    get closeExpired(): Effect.Effect<void> {
        return Effect.flatMap(DateTime.now, now => SubscriptionRef.modify(
            this.ref,
-            entries => HashMap.reduce(
-                entries,
+            HashMap.reduce(
                [
                    Chunk.empty<ScopeRegistryService.Entry>(),
                    HashMap.empty<ScopeRegistryService.Key, ScopeRegistryService.Entry>(),
                ] as const,
+
                ([expired, remaining], entry, key) => Option.exists(
                    entry.expiresAt,
                    expiresAt => DateTime.isLessThanOrEqualTo(expiresAt, now),