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-cassandra.git
The following commit(s) were added to refs/heads/main by this push:
new 8ad2e3e more use of scala.jdk converters (#315)
8ad2e3e is described below
commit 8ad2e3ee5521ff7d7fed7da550d7d48906495cb2
Author: PJ Fanning <[email protected]>
AuthorDate: Sat Sep 27 14:17:07 2025 +0100
more use of scala.jdk converters (#315)
---
docs/src/test/java/jdoc/cleanup/CleanupDocExample.java | 2 +-
dse-test/src/test/scala/your/pack/DseSessionProvider.scala | 4 ++--
.../apache/pekko/persistence/cassandra/example/LoadGenerator.scala | 4 ++--
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/docs/src/test/java/jdoc/cleanup/CleanupDocExample.java
b/docs/src/test/java/jdoc/cleanup/CleanupDocExample.java
index a90ffb1..4a252f1 100644
--- a/docs/src/test/java/jdoc/cleanup/CleanupDocExample.java
+++ b/docs/src/test/java/jdoc/cleanup/CleanupDocExample.java
@@ -15,7 +15,7 @@ import org.apache.pekko.actor.ActorSystem;
import org.apache.pekko.persistence.cassandra.cleanup.Cleanup;
import
org.apache.pekko.persistence.cassandra.query.javadsl.CassandraReadJournal;
import org.apache.pekko.persistence.query.PersistenceQuery;
-import scala.compat.java8.FutureConverters;
+import scala.jdk.javaapi.FutureConverters;
public class CleanupDocExample {
diff --git a/dse-test/src/test/scala/your/pack/DseSessionProvider.scala
b/dse-test/src/test/scala/your/pack/DseSessionProvider.scala
index 5b33d05..8a6db50 100644
--- a/dse-test/src/test/scala/your/pack/DseSessionProvider.scala
+++ b/dse-test/src/test/scala/your/pack/DseSessionProvider.scala
@@ -13,8 +13,8 @@ import
org.apache.pekko.stream.connectors.cassandra.CqlSessionProvider
import com.datastax.dse.driver.api.core.DseSession
import com.datastax.oss.driver.api.core.CqlSession
-import scala.compat.java8.FutureConverters._
import scala.concurrent.{ ExecutionContext, Future }
+import scala.jdk.FutureConverters._
//#dse-session-provider
class DseSessionProvider extends CqlSessionProvider {
@@ -23,7 +23,7 @@ class DseSessionProvider extends CqlSessionProvider {
.builder()
// .withAuthProvider() can add any DSE specific authentication here
.buildAsync()
- .toScala
+ .asScala
}
}
//#dse-session-provider
diff --git
a/example/src/main/scala/org/apache/pekko/persistence/cassandra/example/LoadGenerator.scala
b/example/src/main/scala/org/apache/pekko/persistence/cassandra/example/LoadGenerator.scala
index f802474..c225a19 100644
---
a/example/src/main/scala/org/apache/pekko/persistence/cassandra/example/LoadGenerator.scala
+++
b/example/src/main/scala/org/apache/pekko/persistence/cassandra/example/LoadGenerator.scala
@@ -13,17 +13,17 @@ import org.apache.pekko
import pekko.actor.typed.{ ActorRef, Behavior }
import pekko.actor.typed.scaladsl.Behaviors
import pekko.cluster.sharding.typed.ShardingEnvelope
-import pekko.util.JavaDurationConverters._
import com.typesafe.config.Config
import scala.concurrent.duration.FiniteDuration
+import scala.jdk.DurationConverters._
import scala.util.Random
object LoadGenerator {
object Settings {
def apply(config: Config): Settings = {
- Settings(config.getInt("persistence-ids"),
config.getDuration("load-tick-duration").asScala)
+ Settings(config.getInt("persistence-ids"),
config.getDuration("load-tick-duration").toScala)
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
