diff options
author | vlad <vlad@driver.xyz> | 2017-04-11 16:21:09 -0700 |
---|---|---|
committer | vlad <vlad@driver.xyz> | 2017-04-11 16:21:09 -0700 |
commit | f92036251d778a6c7a0445a46c1fdda930e19cfc (patch) | |
tree | accdaf6c1450745bdbac97a7ba69d46130ad00cc /src/main/scala/xyz/driver/core/database | |
parent | 30d771fe7d2e19c1d26a04bbe0eb771fd8513d67 (diff) | |
download | driver-core-f92036251d778a6c7a0445a46c1fdda930e19cfc.tar.gz driver-core-f92036251d778a6c7a0445a46c1fdda930e19cfc.tar.bz2 driver-core-f92036251d778a6c7a0445a46c1fdda930e19cfc.zip |
Review comments
Diffstat (limited to 'src/main/scala/xyz/driver/core/database')
-rw-r--r-- | src/main/scala/xyz/driver/core/database/Dal.scala | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/main/scala/xyz/driver/core/database/Dal.scala b/src/main/scala/xyz/driver/core/database/Dal.scala index d863e50..1bc3827 100644 --- a/src/main/scala/xyz/driver/core/database/Dal.scala +++ b/src/main/scala/xyz/driver/core/database/Dal.scala @@ -3,7 +3,7 @@ package xyz.driver.core.database import slick.lifted.AbstractTable import scala.concurrent.{ExecutionContext, Future} -import scalaz.{ListT, Monad} +import scalaz.{ListT, Monad, OptionT} import scalaz.std.scalaFuture._ trait Dal { @@ -13,6 +13,12 @@ trait Dal { def execute[D](operations: T[D]): Future[D] def noAction[V](v: V): T[V] def customAction[R](action: => Future[R]): T[R] + + def execute[D](action: => OptionT[T, D]): OptionT[Future, D] = + action.mapT(execute[Option[D]]) + + def customAction[R](action: => OptionT[Future, R]): OptionT[T, R] = + OptionT[T, R](customAction(action.run)) } class FutureDal(executionContext: ExecutionContext) extends Dal { |