This is an automated email from the ASF dual-hosted git repository. hepin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pekko-persistence-jdbc.git
commit a897fac1681b81550596ff2116618a3b5ed6b4c1 Author: JingZhang Chen <[email protected]> AuthorDate: Fri Apr 12 13:43:57 2024 +0800 made it private --- .../scala/org/apache/pekko/persistence/jdbc/journal/dao/BaseDao.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/BaseDao.scala b/core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/BaseDao.scala index 9b58cb6..4bd0114 100644 --- a/core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/BaseDao.scala +++ b/core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/BaseDao.scala @@ -29,7 +29,7 @@ abstract class BaseDao[T] { def baseDaoConfig: BaseDaoConfig - val writeQueue: BoundedSourceQueue[(Promise[Unit], Seq[T])] = Source + private val writeQueue: BoundedSourceQueue[(Promise[Unit], Seq[T])] = Source .queue[(Promise[Unit], Seq[T])](baseDaoConfig.bufferSize) .batchWeighted[(Seq[Promise[Unit]], Seq[T])](baseDaoConfig.batchSize, _._2.size, tup => Vector(tup._1) -> tup._2) { case ((promises, rows), (newPromise, newRows)) => (promises :+ newPromise) -> (rows ++ newRows) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
