Skip to content

Commit ad20b8f

Browse files
author
Francisco Pérez Paradas
authored
Merge pull request #120 from frees-io/fp-recover-asResultSet-tp
Restores asResultSet[M[_]] definition
2 parents 2365dbd + 8899266 commit ad20b8f

File tree

1 file changed

+13
-13
lines changed

1 file changed

+13
-13
lines changed

core/src/main/scala/query/interpolator/package.scala

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -41,44 +41,44 @@ package object interpolator {
4141

4242
import freestyle.cassandra.implicits._
4343

44-
def asResultSet(consistencyLevel: Option[ConsistencyLevel] = None)(
45-
implicit Q: QueryModule[QueryModule.Op]): FreeS[QueryModule.Op, ResultSet] =
46-
Q.sessionAPI.executeWithByteBuffer(tuple._1, tuple._2, consistencyLevel)
44+
def asResultSet[M[_]](consistencyLevel: Option[ConsistencyLevel] = None)(
45+
implicit API: SessionAPI[M]): FreeS[M, ResultSet] =
46+
API.executeWithByteBuffer(tuple._1, tuple._2, consistencyLevel)
4747

48-
def asFree(consistencyLevel: Option[ConsistencyLevel] = None)(
49-
implicit Q: QueryModule[QueryModule.Op]): FreeS[QueryModule.Op, Unit] =
50-
asResultSet(consistencyLevel).map(_ => (): Unit)
48+
def asFree[M[_]](consistencyLevel: Option[ConsistencyLevel] = None)(
49+
implicit API: SessionAPI[M]): FreeS[M, Unit] =
50+
asResultSet[M](consistencyLevel).map(_ => (): Unit)
5151

5252
def as[A](consistencyLevel: Option[ConsistencyLevel] = None)(
5353
implicit Q: QueryModule[QueryModule.Op],
5454
FR: FromReader[A]): FreeS[QueryModule.Op, A] =
55-
asResultSet(consistencyLevel).flatMap(Q.resultSetAPI.read[A](_))
55+
asResultSet[QueryModule.Op](consistencyLevel).flatMap(Q.resultSetAPI.read[A](_))
5656

5757
def asOption[A](consistencyLevel: Option[ConsistencyLevel] = None)(
5858
implicit Q: QueryModule[QueryModule.Op],
5959
FR: FromReader[A]): FreeS[QueryModule.Op, Option[A]] =
60-
asResultSet(consistencyLevel).flatMap(Q.resultSetAPI.readOption[A](_))
60+
asResultSet[QueryModule.Op](consistencyLevel).flatMap(Q.resultSetAPI.readOption[A](_))
6161

6262
def asList[A](consistencyLevel: Option[ConsistencyLevel] = None)(
6363
implicit Q: QueryModule[QueryModule.Op],
6464
FR: FromReader[A]): FreeS[QueryModule.Op, List[A]] =
65-
asResultSet(consistencyLevel).flatMap(Q.resultSetAPI.readList[A](_))
65+
asResultSet[QueryModule.Op](consistencyLevel).flatMap(Q.resultSetAPI.readList[A](_))
6666

6767
def attemptResultSet[M[_]](consistencyLevel: Option[ConsistencyLevel] = None)(
68-
implicit Q: QueryModule[QueryModule.Op],
68+
implicit API: SessionAPI[SessionAPI.Op],
6969
S: Session,
7070
AC: AsyncContext[M],
7171
E: ExecutionContext,
7272
ME: MonadError[M, Throwable]): M[ResultSet] =
73-
asResultSet(consistencyLevel).interpret[M]
73+
asResultSet[SessionAPI.Op](consistencyLevel).interpret[M]
7474

7575
def attempt[M[_]](consistencyLevel: Option[ConsistencyLevel] = None)(
76-
implicit Q: QueryModule[QueryModule.Op],
76+
implicit API: SessionAPI[SessionAPI.Op],
7777
S: Session,
7878
AC: AsyncContext[M],
7979
E: ExecutionContext,
8080
ME: MonadError[M, Throwable]): M[Unit] =
81-
asFree(consistencyLevel).interpret[M]
81+
asFree[SessionAPI.Op](consistencyLevel).interpret[M]
8282

8383
def attemptAs[M[_], A](consistencyLevel: Option[ConsistencyLevel] = None)(
8484
implicit Q: QueryModule[QueryModule.Op],

0 commit comments

Comments
 (0)