Function tryCommit

packages/effect/src/internal/stm/core.ts:238–297

(
  fiberId: FiberId.FiberId,
  stm: STM.STM<A, E, R>,
  state: { value: STMState.STMState<A, E> },
  env: Context.Context<R>,
  scheduler: Scheduler.Scheduler,
  priority: number
)

/** @internal */
const tryCommit = <A, E, R>(
  fiberId: FiberId.FiberId,
  stm: STM.STM<A, E, R>,
  state: { value: STMState.STMState<A, E> },
  env: Context.Context<R>,
  scheduler: Scheduler.Scheduler,
  priority: number
): TryCommit.TryCommit<A, E> => {
  const journal: Journal.Journal = new Map()
  const tExit = new STMDriver(stm, journal, fiberId, env).run()
  const analysis = Journal.analyzeJournal(journal)

  if (analysis === Journal.JournalAnalysisReadWrite) {
    Journal.commitJournal(journal)
  } else if (analysis === Journal.JournalAnalysisInvalid) {
    throw new Error(
      "BUG: STM.TryCommit.tryCommit - please report an issue at https://github.com/Effect-TS/effect/issues"
    )
  }

  switch (tExit._tag) {
    case TExitOpCodes.OP_SUCCEED: {
      state.value = STMState.fromTExit(tExit)
      return completeTodos(Exit.succeed(tExit.value), journal, scheduler, priority)
    }
    case TExitOpCodes.OP_FAIL: {
      state.value = STMState.fromTExit(tExit)
      const cause = Cause.fail(tExit.error)
      return completeTodos(
        Exit.failCause(cause),
        journal,
        scheduler,
        priority
      )
    }
    case TExitOpCodes.OP_DIE: {
      state.value = STMState.fromTExit(tExit)
      const cause = Cause.die(tExit.defect)
      return completeTodos(
        Exit.failCause(cause),
        journal,
        scheduler,
        priority
      )
    }
    case TExitOpCodes.OP_INTERRUPT: {
      state.value = STMState.fromTExit(tExit)
      const cause = Cause.interrupt(fiberId)
      return completeTodos(
        Exit.failCause(cause),
        journal,
        scheduler,
        priority
      )
    }
    case TExitOpCodes.OP_RETRY: {
      return TryCommit.suspend(journal)
    }