StateT[Either] 在 Scalaz 中具有故障转移功能答案

【问题标题】：StateT[Either] with failover in ScalazStateT[Either] 在 Scalaz 中具有故障转移功能
【发布时间】：2017-09-01 09:41:56
【问题描述】：

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

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 的方法。它返回原始State[T] monad 或后备State[T] monad，以防内部EitherTcontains left：

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

如果failover 只是一个值，那将不是问题。我可以使用mapT/mapK 可以访问内部单子的方法，从而能够检查结果是左还是右。在 left 的情况下，我可以使用 fallback 值重新创建内部 monad。但这不是一个值，它本身就是一个 monad，我需要像 flatMapT 这样的东西。

我是否错过了什么，对如何完成有任何想法吗？故障转移实用程序功能对我有很大帮助，不想通过显式的run 调用来破坏中间的链条。

UPD：

上面提到的带值的故障转移可能是这样的：

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：

糟糕的实现打破了整个单子链，中间有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
}

【问题讨论】：

标签： scala scalaz

【解决方案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
}

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

【讨论】：