From 44f5707ddbb80c677bec7f00bd81b889a191593a Mon Sep 17 00:00:00 2001 From: Sebastian Date: Thu, 3 Oct 2024 17:01:13 +0200 Subject: [PATCH] some imports --- .../akka/projection/cassandra/CassandraProjectionTest.java | 3 ++- .../akka/projection/cassandra/CassandraOffsetStoreSpec.scala | 4 +++- .../akka/projection/cassandra/CassandraProjectionSpec.scala | 4 +++- .../akka/projection/internal/OffsetSerializationSpec.scala | 2 +- 4 files changed, 9 insertions(+), 4 deletions(-) diff --git a/akka-projection-cassandra-integration/src/test/java/akka/projection/cassandra/CassandraProjectionTest.java b/akka-projection-cassandra-integration/src/test/java/akka/projection/cassandra/CassandraProjectionTest.java index 9c3a957ad..a894bea1e 100644 --- a/akka-projection-cassandra-integration/src/test/java/akka/projection/cassandra/CassandraProjectionTest.java +++ b/akka-projection-cassandra-integration/src/test/java/akka/projection/cassandra/CassandraProjectionTest.java @@ -31,8 +31,9 @@ import akka.stream.javadsl.Source; import org.junit.*; import org.scalatestplus.junit.JUnitSuite; -import scala.jdk.FutureConverters; + import scala.concurrent.Await; +import scala.jdk.FutureConverters; import java.time.Duration; import java.util.Arrays; diff --git a/akka-projection-cassandra-integration/src/test/scala/akka/projection/cassandra/CassandraOffsetStoreSpec.scala b/akka-projection-cassandra-integration/src/test/scala/akka/projection/cassandra/CassandraOffsetStoreSpec.scala index 3c2173854..f89b9aaef 100644 --- a/akka-projection-cassandra-integration/src/test/scala/akka/projection/cassandra/CassandraOffsetStoreSpec.scala +++ b/akka-projection-cassandra-integration/src/test/scala/akka/projection/cassandra/CassandraOffsetStoreSpec.scala @@ -6,11 +6,13 @@ package akka.projection.cassandra import java.time.Instant import java.util.UUID -import scala.jdk.FutureConverters._ + import scala.concurrent.Await import scala.concurrent.ExecutionContext import scala.concurrent.duration._ +import scala.jdk.FutureConverters._ import scala.util.Try + import akka.Done import akka.actor.Scheduler import akka.actor.testkit.typed.scaladsl.LogCapturing diff --git a/akka-projection-cassandra-integration/src/test/scala/akka/projection/cassandra/CassandraProjectionSpec.scala b/akka-projection-cassandra-integration/src/test/scala/akka/projection/cassandra/CassandraProjectionSpec.scala index d7e00f035..fc4d8d9b8 100644 --- a/akka-projection-cassandra-integration/src/test/scala/akka/projection/cassandra/CassandraProjectionSpec.scala +++ b/akka-projection-cassandra-integration/src/test/scala/akka/projection/cassandra/CassandraProjectionSpec.scala @@ -7,14 +7,16 @@ package akka.projection.cassandra import java.util.UUID import java.util.concurrent.atomic.AtomicInteger import java.util.concurrent.atomic.AtomicReference + import scala.annotation.tailrec import scala.collection.immutable -import scala.jdk.FutureConverters._ import scala.concurrent.Await import scala.concurrent.ExecutionContext import scala.concurrent.Future import scala.concurrent.duration.Duration import scala.concurrent.duration._ +import scala.jdk.FutureConverters._ + import akka.Done import akka.NotUsed import akka.actor.Scheduler diff --git a/akka-projection-core-test/src/test/scala/akka/projection/internal/OffsetSerializationSpec.scala b/akka-projection-core-test/src/test/scala/akka/projection/internal/OffsetSerializationSpec.scala index fa7b65056..9d310d4ba 100644 --- a/akka-projection-core-test/src/test/scala/akka/projection/internal/OffsetSerializationSpec.scala +++ b/akka-projection-core-test/src/test/scala/akka/projection/internal/OffsetSerializationSpec.scala @@ -7,7 +7,6 @@ package akka.projection.internal import java.nio.charset.StandardCharsets import java.util.Base64 import java.util.UUID -import scala.collection.immutable import akka.actor.ExtendedActorSystem import akka.actor.testkit.typed.scaladsl.LogCapturing import akka.actor.testkit.typed.scaladsl.ScalaTestWithActorTestKit @@ -18,6 +17,7 @@ import akka.serialization.SerializerWithStringManifest import org.scalatest.wordspec.AnyWordSpecLike import scala.annotation.unused +import scala.collection.immutable object OffsetSerializationSpec { class TestSerializer(@unused system: ExtendedActorSystem) extends SerializerWithStringManifest {