Skip to content

Commit dff2c59

Browse files
committed
Merge pull request #14 from kxbmap/implicit-ec-param
Added implicit EC parameter to TxAsyncDBSession#begin/rollback/commit
2 parents e7e011a + 2f8af4a commit dff2c59

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

core/src/main/scala/scalikejdbc/async/AsyncDBSession.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -328,11 +328,11 @@ case class TxAsyncDBSession(connection: NonSharedAsyncConnection) extends AsyncD
328328

329329
def isActive: Boolean = connection.isActive
330330

331-
def begin(): Future[AsyncQueryResult] = connection.sendQuery("BEGIN")
331+
def begin()(implicit ctx: EC = ECGlobal): Future[AsyncQueryResult] = connection.sendQuery("BEGIN")
332332

333-
def rollback(): Future[AsyncQueryResult] = connection.sendQuery("ROLLBACK")
333+
def rollback()(implicit ctx: EC = ECGlobal): Future[AsyncQueryResult] = connection.sendQuery("ROLLBACK")
334334

335-
def commit(): Future[AsyncQueryResult] = connection.sendQuery("COMMIT")
335+
def commit()(implicit ctx: EC = ECGlobal): Future[AsyncQueryResult] = connection.sendQuery("COMMIT")
336336

337337
def release(): Unit = connection.release()
338338

0 commit comments

Comments
 (0)