This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-persistence-jdbc.git
The following commit(s) were added to refs/heads/main by this push:
new 64d72a1 close InputStream (#392)
64d72a1 is described below
commit 64d72a1a4ce1a0177746af3c7d1067a8affa61a0
Author: PJ Fanning <[email protected]>
AuthorDate: Sun Nov 30 10:08:57 2025 +0100
close InputStream (#392)
---
.../pekko/persistence/jdbc/testkit/internal/SchemaUtilsImpl.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/core/src/main/scala/org/apache/pekko/persistence/jdbc/testkit/internal/SchemaUtilsImpl.scala
b/core/src/main/scala/org/apache/pekko/persistence/jdbc/testkit/internal/SchemaUtilsImpl.scala
index 2f2a527..91fe9c9 100644
---
a/core/src/main/scala/org/apache/pekko/persistence/jdbc/testkit/internal/SchemaUtilsImpl.scala
+++
b/core/src/main/scala/org/apache/pekko/persistence/jdbc/testkit/internal/SchemaUtilsImpl.scala
@@ -202,7 +202,8 @@ private[jdbc] object SchemaUtilsImpl {
@InternalApi
private[jdbc] def fromClasspathAsString(fileName: String): String = {
val is = getClass.getClassLoader.getResourceAsStream(fileName)
- io.Source.fromInputStream(is).mkString
+ try io.Source.fromInputStream(is).mkString
+ finally is.close()
}
private def loadSlickDatabase(configKey: String)(implicit actorSystem:
ClassicActorSystemProvider) = {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
