fmt

akka · Nov 26, 2024 · 8cfe954 · 8cfe954
1 parent 042ee83
commit 8cfe954
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/akka-projection-r2dbc/src/main/scala/akka/projection/r2dbc/scaladsl/R2dbcSession.scala b/akka-projection-r2dbc/src/main/scala/akka/projection/r2dbc/scaladsl/R2dbcSession.scala
@@ -52,8 +52,10 @@ object R2dbcSession {
     withSession(system, connectionFactory, poolSettings.closeCallsExceeding)(fun)
   }
 
-  @InternalApi private[akka] def withSession[A](system: ActorSystem[_], connectionFactory: ConnectionFactory, closeCallsExceeding: Option[FiniteDuration])(
-    fun: R2dbcSession => Future[A]): Future[A] = {
+  @InternalApi private[akka] def withSession[A](
+      system: ActorSystem[_],
+      connectionFactory: ConnectionFactory,
+      closeCallsExceeding: Option[FiniteDuration])(fun: R2dbcSession => Future[A]): Future[A] = {
     val r2dbcExecutor =
       new R2dbcExecutor(connectionFactory, log, logDbCallsDisabled, closeCallsExceeding)(
         system.executionContext,