Function afterCommit

packages/core/sdk/src/fuma-runtime.ts:108–115

(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(effect);
        })
      : effect.pipe(Effect.ignoreCause({ log: false })),
  );

class TransactionEffectFailure {
  constructor(readonly error: unknown) {}