在 Scalaz 中进行故障转移的 StateT[Either]

Question

我正在尝试在 "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 的方法。 It returns original State[T] monad or fallback State[T] monad in case of inner 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 方法来访问内部 monad，从而能够检查结果是左还是右。在左边的情况下，我可以用 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
}

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
}

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

在 Scalaz 中进行故障转移的 StateT[Either]

StateT[Either] with failover in Scalaz

scala

scalaz