11

我有以下代码使用Readermonad 进行配置并且还必须处理，IO[Option[String]]我最终得到了在我的encode函数中逐步执行的代码。

我如何制定一个 monad 转换器Reader并OptionT避免for我的函数中丑陋的嵌套理解encode？

def encode(fileName: String): Reader[Config, IO[Unit]] = for {
   ffmpegWrapper <- findFfmpegWrapper
   ffmpegBin <- findFfmpeg
} yield (for {
    w <- ffmpegWrapper
    b <- ffmpegBin
    stream <- callFfmpeg(getCommand(w, b, fileName)).liftM[OptionT]
} yield stream) map (_ foreach (println)) getOrElse Unit.box {}


def getCommand(ffmpegWrapper: String, ffmpegBin: String,
             videoFile: String) = s"$ffmpegWrapper $ffmpegBin $videoFile  '-vcodec libx264 -s 1024x576' /tmp/out.mp4"

def callFfmpeg(command: String): IO[Stream[String]] = IO {
  Process(command).lines_!
}

def findFile(path:List[String]): OptionT[IO,String] = OptionT[IO,String](IO{path.find(new File(_).exists)})

def findFfmpeg:Reader[Config, OptionT[IO,String]] = Reader {c=>findFile(c.ffmpegLocations)}

def findFfmpegWrapper:Reader[Config, OptionT[IO,String]] = Reader {c=>findFile(c.ffmpegWrapperLocations)}

谢谢！

4

1 回答 1

13

如果您查看Scalaz 源代码中的定义Reader，您会看到：

    type Reader[-E, +A] = ReaderT[Id, E, A]

这告诉我们，Reader您正在使用的 monad 只是 monad 转换器的一个特化，其中被包裹的 monad 是琐碎的Idmonad。您可以ReaderT直接使用，但将您的OptionT[IO, _]monad 包装起来，而不是将所有内容都包装在Reader. 例如，以下应该做你想要的：

type OptionIO[+A] = OptionT[IO, A]

def findFfmpeg: ReaderT[OptionIO, Config, String] =
  Kleisli[OptionIO, Config, String](c => findFile(c.ffmpegLocations))

def findFfmpegWrapper: ReaderT[OptionIO, Config, String] =
  Kleisli[OptionIO, Config, String](c => findFile(c.ffmpegWrapperLocations))

def encode(fileName: String): ReaderT[OptionIO, Config, Unit] = (for {
   w <- findFfmpegWrapper
   b <- findFfmpeg
   stream <- Kleisli[OptionIO, Config, Stream[String]](
     _ => callFfmpeg(getCommand(w, b, fileName)).liftM[OptionT]
   )
} yield stream).map(_ foreach println)

原则上，您应该能够stream <-使用以下内容更换零件：

callFfmpeg(getCommand(w, b, fileName)).liftM[OptionT].liftReaderT[Config]

但由于某种原因Unapply，所依赖的机器liftReaderT在这种情况下似乎不起作用。幸运的是，明确地写出这Kleisli部分并不是那么可怕。

作为脚注：如果您定义这样的实例，liftReaderT则可以使用我提到的漂亮语法：UnapplyCo

implicit def unapplyMFA1[TC[_[_]], F[+_], M0[F[+_], +_], A0](
  implicit TC0: TC[({ type L[x] = M0[F, x] })#L]
): UnapplyCo[TC, M0[F, A0]] {
  type M[+X] = M0[F, X]
  type A = A0
} = new UnapplyCo[TC, M0[F, A0]] {
  type M[+X] = M0[F, X]
  type A = A0
  def TC = TC0
  def leibniz = Leibniz.refl
}

我不确定Scalaz 7目前不提供此实例是否有原因，但它可能值得研究。

于 2013-06-12T13:10:19.030 回答