Function afterCommitRequired

packages/core/sdk/src/fuma-runtime.ts:266–275

(
  effect: Effect.Effect<void, StorageFailure>,
)

 * required finalizers after commit and then reports any combined failure.
 */
export const afterCommitRequired = (
  effect: Effect.Effect<void, StorageFailure>,
): Effect.Effect<void, StorageFailure> =>
  Effect.flatMap(Effect.service(pendingCommitHooksRef), (hooks) =>
    hooks
      ? Effect.sync(() => {
          hooks.push({ _tag: "Required", effect });
        })
      : effect,
  );

const runCommitHooks = (hooks: readonly PendingCommitHook[]): Effect.Effect<void, StorageFailure> =>
  Effect.gen(function* () {