12

scala の Future (2.10) を新しい scalaz7 future に適切に変換する方法を知っている人はいますか? scala Promise を介して scalaz future を scala Future に変換する方法は知っていますが、適切に変換する方法がわかりません。

例えば

import scalaz.concurrent.{Future => Zuture}
import scala.concurrent.Future

実装したい

implicit def scalaF2scalazF[A](in:Future[A]):Zuture[A]=???

それから明らかに簡単に書くことができます

implicit def scalaF2scalazTask[A](in:Future[A]):Task[A]=???

それが私が本当に欲しいものだから:-)

4

2 に答える 2

21

いくつかの代替案を評価した後、次の解決策にたどり着きました。明らかに誰かが望むならscalaz.Monad[scala.concurrent.Future]、scalaz.std.scalaFuture https://github.com/scalaz/scalaz/blob/series/7.2.x/core/src/main/scala/scalaz/std/Future.scala#L85が道です。

object ScalaFutureConverters {


  implicit def scalaFuture2scalazTask[T](fut: Future[T])(implicit ec: ExecutionContext): Task[T] = {
    Task.async {
      register =>
        fut.onComplete {
          case Success(v) => register(v.right)
          case Failure(ex) => register(ex.left)
        }
    }
  }


  implicit def scalazTask2scalaFuture[T](task: Task[T]): Future[T] = {
    val p: Promise[T] = Promise()

    task.runAsync {
      case -\/(ex) => p.failure(ex)
      case \/-(r) => p.success(r)
    }

    p.future
  }


  implicit class ScalazFutureEnhancer[T](task: Task[T]) {
    def asScala: Future[T] = scalazTask2scalaFuture(task)
  }


  implicit def scalaF2EnhancedScalaF[T](fut: Future[T])(implicit ec: ExecutionContext): ScalaFEnhancer[T] =
    ScalaFEnhancer(fut)(ec)

  case class ScalaFEnhancer[T](fut: Future[T])(implicit ec: ExecutionContext) {
    def asTask: Task[T] = scalaFuture2scalazTask(fut)(ec)
  }

}

ただし、このソリューションは、状況に応じて、必要な場合とそうでない場合がある scala future への変換が行われると、タスクも実行します。

于 2013-06-29T07:18:41.343 に答える
1

便利なメソッドを追加するhttps://github.com/Verizon/deloreanを使用することもできますtoTasktoFuture

于 2017-07-10T18:36:01.327 に答える