-
A[B[C]]
という型のオブジェクトがあったときにA
がTraverse
、B
がApplicative
ならば、sequence
という関数を呼ぶだけで、A[B[C]]
からB[A[C]]
に変換できます。 -
Option
はTraverse
であり、Future
はApplicative
です。 -
なので、
Option[Future[A]]
はFuture[Option[A]]
に変換できます。 -
a.map(_.sequence.map(_.join)).join
を1つずつ説明すると -
まず
a.map(_.sequence)
で、真ん中のOption
とFuture
が入れ替わりFuture[Future[Option[Option[Int]]]]
になります。 -
また、
M[M[A]]
という型があった場合に、もしM
がMonad
ならば(正確にはBind
ならば)join
を呼ぶだけでM[M[A]]
をM[A]
に変換できます。 -
Future
もOption
もMonad
なのでjoin
が使えます。 -
a.map(_.sequence.map(_.join))
でFuture[Future[Option[Int]]]
と、内側の2重のOption
を潰したということです。 -
最後の
join
で、外側の2重のFuture
を潰して完成です。 -
ちなみに、上記では説明の都合上個別に呼び出しましたが
a.map(_.sequence.map(_.join)).join
はa.flatMap(_.sequence.map(_.join))
とも書けます
Last active
January 4, 2016 18:49
-
-
Save xuwei-k/8662956 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
libraryDependencies += "org.scalaz" %% "scalaz-core" % "7.1.3" |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Welcome to Scala version 2.11.7 (Java HotSpot(TM) 64-Bit Server VM, Java 1.8.0_45). | |
Type in expressions to have them evaluated. | |
Type :help for more information. | |
scala> import scalaz._, syntax.traverse._, std.scalaFuture._, std.option._, syntax.bind._ | |
import scalaz._ | |
import syntax.traverse._ | |
import std.scalaFuture._ | |
import std.option._ | |
import syntax.bind._ | |
scala> import scala.concurrent._ | |
import scala.concurrent._ | |
scala> import scala.concurrent.ExecutionContext.Implicits._ | |
import scala.concurrent.ExecutionContext.Implicits._ | |
scala> val a: Future[Option[Future[Option[Int]]]] = Future(None) | |
a: scala.concurrent.Future[Option[scala.concurrent.Future[Option[Int]]]] = scala.concurrent.impl.Promise$DefaultPromise@358404f5 | |
scala> a.map(_.sequence.map(_.join)).join | |
res0: scala.concurrent.Future[Option[Int]] = scala.concurrent.impl.Promise$DefaultPromise@b340942 |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment