Секвенирование Scalaz WriterT и Either с помощью for-yield
Если у меня есть:
import scala.concurrent._
import scalaz._, Scalaz._
type Z = List[String]
type F[α] = Future[α]
type WT[α] = WriterT[F, Z, α]
implicit val z: Monoid[Z] = new Monoid[Z] {
def zero = Nil
def append (f1: Z, f2: => Z) = f1 ::: f2
}
implicit val f: Monad[F] = scalaz.std.scalaFuture.futureInstance
Я могу написать код так:
def fooA (): WT[Int] = WriterT.put[F, Z, Int] (f.point (18))(z.zero)
def fooB (): WT[Int] = WriterT.put[F, Z, Int] (f.point (42))(z.zero)
def fooLog (msg: String): WT[Unit] = WriterT.put[F, Z, Unit] (f.point (()))(msg :: Nil))
def foo (): WT[Int] = for {
_: Unit <- fooLog ("log #1")
a: Int <- fooA
_: Unit <- fooLog ("log #2")
b: Int <- fooB
_: Unit <- fooLog ("log #3")
} yield a + b
Предположим, я определил:
type WTT[α] = WriterT[Future, Z, Throwable \/ α]
def flakeyInt (i: Int): Throwable \/ Int = new java.util.Random().nextBoolean match {
case false => i.right
case true => new Exception (":-(").left
}
Я могу тогда написать это:
def barA (): WTT[Int] = WriterT.put[F, Z, Throwable \/ Int] (f.point (flakeyInt (18)))(z.zero)
def barB (): WTT[Int] = WriterT.put[F, Z, Throwable \/ Int] (f.point (flakeyInt (42)))(z.zero)
def barLog (msg: String): WTT[Unit] = WriterT.put[F, Z, Throwable \/ Unit] (f.point (().right))(msg :: Nil))
def bar (): WTT[Int] = for {
_: Throwable \/ Unit <- barLog ("log #1")
x: Throwable \/ Int <- barA
_: Throwable \/ Unit <- barLog ("log #2")
y: Throwable \/ Int <- barB
_: Throwable \/ Unit <- barLog ("log #3")
} yield {
for {
a <- x
b <- y
} yield a + b
}
Есть ли способ сделать <-
в типе возврата для доходности α
не \/[Throwable, α]
так что мне не нужно вручную выравнивать Throwables в конце? В идеале я хотел бы сделать bar
функция выглядит как foo
функция, чтобы я мог скрыть сглаживание ошибок от логики.
Контрольный вопрос:
1 ответ
Вы должны обернуть свою будущую монаду в EitherT, слегка изменяя ваш код. Это будет выглядеть так:
type EFT[α] = EitherT[F, Throwable, α]
type WEFT[α] = WriterT[EFT, Z, α]
def bazA(): WEFT[Int] = WriterT.put[EFT, Z, Int](EitherT.right[F, Throwable, Int](f.point(18)))(z.zero)
def bar(): WEFT[Int] = for {
a <- bazA
b <- bazA
} yield a + b
Вы также можете определить функции подъема (который поднимает значение от одной монады к вашему трансформатору), чтобы избежать шаблонов.
def liftW[A](fa: Future[A]): WLET[A] = {
WriterT.put[MLT, Z, A](EitherT.right[Future, Throwable, A](fa))(z.zero)
}
def bbar(): WLET[Int] = for {
a ← liftW(6.point[F])
b ← liftW(6.point[F])
} yield a + b
Я уверен, что функции подъема присутствуют в scalaZ, но я всегда изо всех сил пытаюсь найти их, и кажется, что иногда их легче написать самостоятельно.