From 8cfe954a9fb94f9b984bad210d5d7ce584181f0e Mon Sep 17 00:00:00 2001 From: Sebastian Date: Tue, 26 Nov 2024 13:41:38 +0100 Subject: [PATCH] fmt --- .../scala/akka/projection/r2dbc/scaladsl/R2dbcSession.scala | 6 ++++-- 1 file changed, 4 insertions(+), 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 index ac9261986..cce6cf811 100644 --- 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,