让我们在“\/”上定义一个Kleisli:
在上述过程中,我首先将
最后一个问题。
不确定为什么在管道切换到
来源: 这里,scalaz,这里 和 real world haskell on transformers。
abstract class MyError
case class NumericalError(msg: String) extends MyError
// Either is a Monad with two type parameters: M[A,B] which represent left and right respectively
// Let's create an ad-hoc type
type EEither[+T] = \/[MyError, T]
还有一个用于测试目的的特别函数:
def safeSqrtEither(t: Double): EEither[Double] =
safeSqrtOpt(t) match {
case Some(r) => r.right
case None => NumericalError("Sqrt on double is not define if _ < 0").left
}
val kSafeSqrtEither = Kleisli.kleisli( (x: Double) => safeSqrtEither(x) )
函数组合可以很顺畅地工作:
val pipeEither = kSafeSqrtEither >>> kSafeSqrtEither
val r5b = pipeEither2 run 16.0
//which gives r5b: EEither[Double] = \/-(2.0)
我想添加日志记录:
type LoggedROCFun[I,O] = I => WriterT[EEither,scalaz.NonEmptyList[String],O]
val sqrtWithLog: LoggedROCFun[Double, Double] =
(t: Double) =>
WriterT.put(kSafeSqrtEither(t))(s"squared $t".wrapNel)
这似乎具有所需的行为:
val resA = sqrtWithLog(16.0)
// resA: scalaz.WriterT[EEither,scalaz.NonEmptyList[String],Double] = WriterT(\/-((NonEmpty[squared 16.0],4.0)))
简洁明了。然而,我正在努力编写一个操作器来:
- 将
WriterT
中的值应用>>>
进行合并 - 连接(附加)每个日志,追踪每一步所做的记录
期望输出:
val combinedFunction = sqrtWithLog >>> sqrtWithLog
val r = combinedFunction run 16.0
// r: WriterT(\/-((NonEmpty[squared 16.0, squared 4.0],2.0)))
我的最佳尝试:
def myCompositionOp[I,A,B](f1: LoggedROCFun[I,A])(f2: LoggedROCFun[A,B]): LoggedROCFun[I,B] =
(x: I) => {
val e = f1.apply(x)
val v1: EEither[A] = e.value
v1 match {
case Right(v) => f2(v)
case Left(err) =>
val lastLog = e.written
val v2 = err.left[B]
WriterT.put(v2)(lastLog)
}
}
在上述过程中,我首先将
f1
应用于x
,然后将结果传递给f2
。否则,我会直接跳转到Left
。这是错误的,因为在Right
的情况下,我会丢弃之前的日志记录。最后一个问题。
val safeDivWithLog: Kleisli[W, (Double,Double), Double] =
Kleisli.kleisli[W, (Double, Double), Double]( (t: (Double, Double)) => {
val (n,d) = t
WriterT.put(safeDivEither(t))(s"divided $n by $d".wrapNel)
}
)
val combinedFunction2 = safeDivWithLog >>> sqrtWithLog
val rAgain = combinedFunction2 run (-10.0,2.0)
// rAgain: W[Double] = WriterT(-\/(NumericalError(Sqrt on double is not define if _ < 0)))
不确定为什么在管道切换到
Left
后,日志为何没有传递。是因为:
- 类型 MyMonad e w a = ErrorT e (Writer w) a 等同于 (Either e a, w)
- 类型 MyMonad e w a = WriterT w (Either e) a 等同于 Either r (a, w)
来源: 这里,scalaz,这里 和 real world haskell on transformers。
Left
时,WriterT
会丢弃日志(请参见上文)。谢谢。 - NoIdeaHowToFixThis