Секвенирование 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 функция, чтобы я мог скрыть сглаживание ошибок от логики.

Контрольный вопрос:

Настройка композиции Future, Either и Writer в Scalaz

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, но я всегда изо всех сил пытаюсь найти их, и кажется, что иногда их легче написать самостоятельно.

Другие вопросы по тегам