Method run

packages/effect/src/internal/stm/core.ts:474–586

()

  }

  run(): TExit.TExit<A, E> {
    let curr = this.self as Primitive | Context.Tag<any, any> | Either.Either<any, any> | Option.Option<any> | undefined
    let exit: TExit.TExit<unknown, unknown> | undefined = undefined
    while (exit === undefined && curr !== undefined) {
      try {
        const current = curr
        if (current) {
          switch (current._op) {
            case "Tag": {
              curr = effect((_, __, env) => Context.unsafeGet(env, current)) as Primitive
              break
            }
            case "Left": {
              curr = fail(current.left) as Primitive
              break
            }
            case "None": {
              curr = fail(new Cause.NoSuchElementException()) as Primitive
              break
            }
            case "Right": {
              curr = succeed(current.right) as Primitive
              break
            }
            case "Some": {
              curr = succeed(current.value) as Primitive
              break
            }
            case "Commit": {
              switch (current.effect_instruction_i0) {
                case OpCodes.OP_DIE: {
                  exit = TExit.die(internalCall(() => current.effect_instruction_i1()))
                  break
                }
                case OpCodes.OP_FAIL: {
                  const cont = this.nextFailure()
                  if (cont === undefined) {
                    exit = TExit.fail(internalCall(() => current.effect_instruction_i1()))
                  } else {
                    curr = internalCall(() =>
                      cont.effect_instruction_i2(
                        internalCall(() => current.effect_instruction_i1())
                      ) as Primitive
                    )
                  }
                  break
                }
                case OpCodes.OP_RETRY: {
                  const cont = this.nextRetry()
                  if (cont === undefined) {
                    exit = TExit.retry
                  } else {
                    curr = internalCall(() => cont.effect_instruction_i2() as Primitive)
                  }
                  break
                }
                case OpCodes.OP_INTERRUPT: {
                  exit = TExit.interrupt(this.fiberId)