scala - Scalaz 中具有故障转移功能的 StateT[Eii]

Question

我正在尝试在 "scalaz-core"%"7.2.14" StateT monad 的组合中创建某种故障转移行为。

StateT monad 包裹 EitherT，因此它是一个 monad 转换器:

type Error = String
type ErrOrT[T] = Error \/ T
type State[T] = StateT[ErrOrT, String, T]

使用这些类型，一切都很好 - 我可以利用 Either 和 State 的力量。如果出现错误，我会发生短路，并且可以将我的状态堆叠在一个一元组合中:

def func1: State[Int] = ???
def func2: State[Int] = ???
def func3: State[Int] = ???

val stateMonad = for {
  res1 <- func1
  res2 <- func2
  res3 <- func3
} yield res3

此外，我想创建类似 tryWithFailover 方法的东西。如果内部 EitherT 包含 left:它返回原始 State[T] monad 或后备 State[T] monad:

def tryWithFailover[T](run: State[T])(failover: Error => State[T]): State[T] = ???

因此生成的链将是:

val stateMonad = for {
  res1 <- func1
  res2 <- tryWithFailover(func2)(err => failover)
  res3 <- func3
} yield res3

如果故障转移只是一个值，那么就不会出现问题。我可以使用 mapT/mapK 方法来访问内部 monad，从而能够检查结果是左还是右。如果是 left，我可以使用 fallback 值重新创建内部 monad。但它不是一个值，它本身就是一个 monad，我需要像 flatMapT 这样的东西。

我是否错过了什么，有没有想过如何完成它？故障转移 util 函数会对我有很大帮助，我不想通过显式的 run 调用来破坏中间的链条。

<小时/>

更新:

上述具有值(value)的故障转移可能是这样的:

def tryWithFailover[T](run: State[T])(failover: Error => T): State[T] = {
  for {
    lockedState <- State(st => (st, st))
    result <- run.mapT[ErrOrT, T, String] {
      case ok@ \/-(_) => ok
      case -\/(error) => \/-((lockedState, failover(error)))
    }
  } yield result
}

<小时/>

UPD2:

糟糕的实现破坏了整个单子(monad)链，中间有 run:

def tryWithFailover[T](run: State[T])(failover: Error => State[T]): State[T] = {
  for {
    lockedState <- State(st => (st, st))
    result <- run.mapT[ErrOrT, T, String] {
      case ok@ \/-(_) => ok
      case -\/(error) => failover(error).run(lockedState)
    }
  } yield result
}

Answer 1

经过一番考虑，我得出的结论是，上述方法还不错:

def tryWithFailover[T](run: State[T])(failover: Error => State[T]): State[T] = {
  for {
    lockedState <- State(st => (st, st))
    result <- run.mapT[ErrOrT, T, String] {
      case ok@DRight(_) => ok
      case DLeft(error) => failover(error).run(lockedState)
    }
  } yield result
}

也许有一天有人会纠正我的答案。