Function afterCommit

packages/core/sdk/src/fuma-runtime.ts:252–259

(effect: Effect.Effect<void>)

);

export const afterCommit = (effect: Effect.Effect<void>): Effect.Effect<void> =>
  Effect.flatMap(Effect.service(pendingCommitHooksRef), (hooks) =>
    hooks
      ? Effect.sync(() => {
          hooks.push({ _tag: "Observer", effect });
        })
      : effect.pipe(Effect.ignoreCause({ log: false })),
  );

/**
 * Run a required external finalizer after the outermost database commit.