diff options
author | Stewart Stewart <stewinsalot@gmail.com> | 2016-12-19 20:37:40 -0500 |
---|---|---|
committer | Stewart Stewart <stewinsalot@gmail.com> | 2016-12-19 20:44:46 -0500 |
commit | a32427bca195ef4eb1cc0f326d27b990402e6c63 (patch) | |
tree | b0f5413d4620756c912037afa930cab0f0551f9a /src | |
parent | 548338adc1691ea667f7941bfc65f8a6d6ce2c0e (diff) | |
download | driver-core-a32427bca195ef4eb1cc0f326d27b990402e6c63.tar.gz driver-core-a32427bca195ef4eb1cc0f326d27b990402e6c63.tar.bz2 driver-core-a32427bca195ef4eb1cc0f326d27b990402e6c63.zip |
update sbt-settings (for scalaz 2.7.8 with `mapT`)
Diffstat (limited to 'src')
-rw-r--r-- | src/main/scala/xyz/driver/core/database/Dal.scala | 20 |
1 files changed, 4 insertions, 16 deletions
diff --git a/src/main/scala/xyz/driver/core/database/Dal.scala b/src/main/scala/xyz/driver/core/database/Dal.scala index b476c0d..e920392 100644 --- a/src/main/scala/xyz/driver/core/database/Dal.scala +++ b/src/main/scala/xyz/driver/core/database/Dal.scala @@ -2,7 +2,7 @@ package xyz.driver.core.database import scala.concurrent.{ExecutionContext, Future} -import scalaz.{ListT, Monad, OptionT} +import scalaz.{ListT, Monad} import scalaz.std.scalaFuture._ trait Dal { @@ -10,8 +10,6 @@ trait Dal { protected implicit val monadT: Monad[T] protected def execute[D](operations: T[D]): Future[D] - protected def execute[D](readOperations: OptionT[T, D]): OptionT[Future, D] - protected def execute[D](readOperations: ListT[T, D]): ListT[Future, D] protected def noAction[V](v: V): T[V] protected def customAction[R](action: => Future[R]): T[R] } @@ -21,11 +19,9 @@ class FutureDal(executionContext: ExecutionContext) extends Dal { override type T[D] = Future[D] implicit val monadT = implicitly[Monad[Future]] - def execute[D](operations: T[D]): Future[D] = operations - def execute[D](operations: OptionT[T, D]): OptionT[Future, D] = OptionT(operations.run) - def execute[D](operations: ListT[T, D]): ListT[Future, D] = ListT(operations.run) - def noAction[V](v: V): T[V] = Future.successful(v) - def customAction[R](action: => Future[R]): T[R] = action + def execute[D](operations: T[D]): Future[D] = operations + def noAction[V](v: V): T[V] = Future.successful(v) + def customAction[R](action: => Future[R]): T[R] = action } class SlickDal(database: Database, executionContext: ExecutionContext) extends Dal { @@ -46,14 +42,6 @@ class SlickDal(database: Database, executionContext: ExecutionContext) extends D database.database.run(readOperations.transactionally) } - override def execute[D](readOperations: OptionT[T, D]): OptionT[Future, D] = { - OptionT(database.database.run(readOperations.run.transactionally)) - } - - override def execute[D](readOperations: ListT[T, D]): ListT[Future, D] = { - ListT(database.database.run(readOperations.run.transactionally)) - } - override def noAction[V](v: V): T[V] = DBIO.successful(v) override def customAction[R](action: => Future[R]): T[R] = DBIO.from(action) } |