-
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 hidden or 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 hidden or 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