diff --git a/akka-actor-tests/src/test/java/akka/event/ActorWithMDC.java b/akka-actor-tests/src/test/java/akka/event/ActorWithMDC.java index 90dc37e5d59..7879b873c86 100644 --- a/akka-actor-tests/src/test/java/akka/event/ActorWithMDC.java +++ b/akka-actor-tests/src/test/java/akka/event/ActorWithMDC.java @@ -5,7 +5,6 @@ package akka.event; import akka.actor.AbstractActor; -import akka.japi.pf.ReceiveBuilder; import java.util.Collections; import java.util.LinkedHashMap; diff --git a/akka-actor-tests/src/test/java/akka/japi/ThrowablesTest.java b/akka-actor-tests/src/test/java/akka/japi/ThrowablesTest.java index a2822d603e9..7a23352951c 100644 --- a/akka-actor-tests/src/test/java/akka/japi/ThrowablesTest.java +++ b/akka-actor-tests/src/test/java/akka/japi/ThrowablesTest.java @@ -6,7 +6,6 @@ import org.junit.Assert; import org.junit.Test; -import scala.util.control.ControlThrowable; public class ThrowablesTest { @Test diff --git a/akka-actor-tests/src/test/java/akka/japi/pf/ReceiveBuilderTest.java b/akka-actor-tests/src/test/java/akka/japi/pf/ReceiveBuilderTest.java index b8b921d06a3..73034fdfb74 100644 --- a/akka-actor-tests/src/test/java/akka/japi/pf/ReceiveBuilderTest.java +++ b/akka-actor-tests/src/test/java/akka/japi/pf/ReceiveBuilderTest.java @@ -11,7 +11,6 @@ import org.scalatestplus.junit.JUnitSuite; import akka.actor.AbstractActor.Receive; -import org.scalatestplus.junit.JUnitSuite; import static org.junit.Assert.*; diff --git a/akka-actor-tests/src/test/java/akka/pattern/PatternsTest.java b/akka-actor-tests/src/test/java/akka/pattern/PatternsTest.java index 8be45e2fe56..7dc9d06b63e 100644 --- a/akka-actor-tests/src/test/java/akka/pattern/PatternsTest.java +++ b/akka-actor-tests/src/test/java/akka/pattern/PatternsTest.java @@ -21,7 +21,6 @@ import java.util.Arrays; import java.util.concurrent.*; import java.time.Duration; -import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import static akka.pattern.Patterns.ask; diff --git a/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/ActorContextPipeToSelfTest.java b/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/ActorContextPipeToSelfTest.java index 307c335e023..e7cb9baf9ce 100644 --- a/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/ActorContextPipeToSelfTest.java +++ b/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/ActorContextPipeToSelfTest.java @@ -11,7 +11,6 @@ import akka.actor.typed.ActorRef; import akka.actor.typed.Behavior; import akka.actor.typed.Props; -import akka.actor.typed.Signal; import com.typesafe.config.ConfigFactory; import org.junit.ClassRule; import org.junit.Rule; diff --git a/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/ReceiveBuilderTest.java b/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/ReceiveBuilderTest.java index cce12b9a907..41290b9b249 100644 --- a/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/ReceiveBuilderTest.java +++ b/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/ReceiveBuilderTest.java @@ -17,7 +17,6 @@ import akka.actor.typed.Behavior; import static akka.actor.typed.javadsl.Behaviors.same; -import static org.junit.Assert.assertEquals; /** Test creating [[MutableActor]]s using [[ReceiveBuilder]] */ public class ReceiveBuilderTest extends JUnitSuite { diff --git a/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/RoutersTest.java b/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/RoutersTest.java index fdd2c2050e0..14cbe54c019 100644 --- a/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/RoutersTest.java +++ b/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/RoutersTest.java @@ -16,8 +16,6 @@ import org.junit.Test; import org.scalatestplus.junit.JUnitSuite; -import java.util.List; - import static org.junit.Assert.assertEquals; public class RoutersTest extends JUnitSuite { diff --git a/akka-actor/src/main/java/akka/dispatch/AbstractBoundedNodeQueue.java b/akka-actor/src/main/java/akka/dispatch/AbstractBoundedNodeQueue.java index 9fd9b6b24e2..5c9234f8ba3 100644 --- a/akka-actor/src/main/java/akka/dispatch/AbstractBoundedNodeQueue.java +++ b/akka-actor/src/main/java/akka/dispatch/AbstractBoundedNodeQueue.java @@ -6,8 +6,6 @@ import akka.util.Unsafe; -import java.util.concurrent.atomic.AtomicReference; - /** * Lock-free bounded non-blocking multiple-producer single-consumer queue based on the works of: * diff --git a/akka-actor/src/main/java/akka/dispatch/affinity/OnSpinWait.java b/akka-actor/src/main/java/akka/dispatch/affinity/OnSpinWait.java index d9dd623abd6..49e26152cf4 100644 --- a/akka-actor/src/main/java/akka/dispatch/affinity/OnSpinWait.java +++ b/akka-actor/src/main/java/akka/dispatch/affinity/OnSpinWait.java @@ -4,7 +4,6 @@ package akka.dispatch.affinity; -import akka.util.Unsafe; import java.lang.invoke.MethodHandle; import java.lang.invoke.MethodHandles; import akka.annotation.InternalApi; diff --git a/akka-bench-jmh/src/main/java/akka/serialization/jackson/JavaMessages.java b/akka-bench-jmh/src/main/java/akka/serialization/jackson/JavaMessages.java index 7052554bf02..53c80defefc 100644 --- a/akka-bench-jmh/src/main/java/akka/serialization/jackson/JavaMessages.java +++ b/akka-bench-jmh/src/main/java/akka/serialization/jackson/JavaMessages.java @@ -4,8 +4,6 @@ package akka.serialization.jackson; -import com.fasterxml.jackson.annotation.JsonCreator; - import java.time.Duration; import java.time.Instant; import java.time.LocalDateTime; diff --git a/akka-cluster-tools/src/test/java/akka/cluster/singleton/ClusterSingletonManagerTest.java b/akka-cluster-tools/src/test/java/akka/cluster/singleton/ClusterSingletonManagerTest.java index 6f72d00c26c..aefdea233ea 100644 --- a/akka-cluster-tools/src/test/java/akka/cluster/singleton/ClusterSingletonManagerTest.java +++ b/akka-cluster-tools/src/test/java/akka/cluster/singleton/ClusterSingletonManagerTest.java @@ -6,9 +6,6 @@ import akka.actor.ActorSystem; -import java.util.HashMap; -import java.util.Map; - import akka.actor.ActorRef; import akka.actor.Props; diff --git a/akka-cluster-typed/src/test/java/jdocs/akka/cluster/typed/PingSerializerExampleTest.java b/akka-cluster-typed/src/test/java/jdocs/akka/cluster/typed/PingSerializerExampleTest.java index 4f48f0ccdbe..3a2317079f3 100644 --- a/akka-cluster-typed/src/test/java/jdocs/akka/cluster/typed/PingSerializerExampleTest.java +++ b/akka-cluster-typed/src/test/java/jdocs/akka/cluster/typed/PingSerializerExampleTest.java @@ -10,7 +10,6 @@ import akka.actor.typed.javadsl.Adapter; import akka.serialization.SerializerWithStringManifest; -import java.io.NotSerializableException; import java.nio.charset.StandardCharsets; public class PingSerializerExampleTest { diff --git a/akka-distributed-data/src/test/java/akka/cluster/ddata/JavaImplOfDeltaReplicatedData2.java b/akka-distributed-data/src/test/java/akka/cluster/ddata/JavaImplOfDeltaReplicatedData2.java index 776428e8e91..4eca7784ec8 100644 --- a/akka-distributed-data/src/test/java/akka/cluster/ddata/JavaImplOfDeltaReplicatedData2.java +++ b/akka-distributed-data/src/test/java/akka/cluster/ddata/JavaImplOfDeltaReplicatedData2.java @@ -6,8 +6,6 @@ import java.util.Optional; -import akka.cluster.UniqueAddress; - // different delta type public class JavaImplOfDeltaReplicatedData2 extends AbstractDeltaReplicatedData< diff --git a/akka-docs/src/test/java/jdocs/actor/ActorDocTest.java b/akka-docs/src/test/java/jdocs/actor/ActorDocTest.java index ff90e0e2b56..3b6c7cc1ddf 100644 --- a/akka-docs/src/test/java/jdocs/actor/ActorDocTest.java +++ b/akka-docs/src/test/java/jdocs/actor/ActorDocTest.java @@ -13,8 +13,6 @@ import static jdocs.actor.Messages.*; import akka.actor.CoordinatedShutdown; -import akka.Done; - import java.util.Optional; import java.util.concurrent.TimeUnit; import java.time.Duration; diff --git a/akka-docs/src/test/java/jdocs/actor/typed/DispatcherDocTest.java b/akka-docs/src/test/java/jdocs/actor/typed/DispatcherDocTest.java index 04219e2699e..17bad4cc564 100644 --- a/akka-docs/src/test/java/jdocs/actor/typed/DispatcherDocTest.java +++ b/akka-docs/src/test/java/jdocs/actor/typed/DispatcherDocTest.java @@ -4,8 +4,6 @@ package jdocs.actor.typed; -import java.util.concurrent.Executor; - import scala.concurrent.ExecutionContextExecutor; import akka.actor.typed.*; diff --git a/akka-docs/src/test/java/jdocs/cluster/FactorialFrontendMain.java b/akka-docs/src/test/java/jdocs/cluster/FactorialFrontendMain.java index f6c0c9a817f..7c93dd9daa9 100644 --- a/akka-docs/src/test/java/jdocs/cluster/FactorialFrontendMain.java +++ b/akka-docs/src/test/java/jdocs/cluster/FactorialFrontendMain.java @@ -5,8 +5,6 @@ package jdocs.cluster; import java.util.concurrent.TimeUnit; -import scala.concurrent.Await; -import scala.concurrent.duration.Duration; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; diff --git a/akka-docs/src/test/java/jdocs/ddata/DistributedDataDocTest.java b/akka-docs/src/test/java/jdocs/ddata/DistributedDataDocTest.java index a9b9a151fee..31bc04461c6 100644 --- a/akka-docs/src/test/java/jdocs/ddata/DistributedDataDocTest.java +++ b/akka-docs/src/test/java/jdocs/ddata/DistributedDataDocTest.java @@ -23,7 +23,6 @@ import org.junit.AfterClass; import org.junit.BeforeClass; -import akka.cluster.Cluster; import akka.cluster.ddata.*; import akka.japi.pf.ReceiveBuilder; diff --git a/akka-docs/src/test/java/jdocs/dispatcher/DispatcherDocTest.java b/akka-docs/src/test/java/jdocs/dispatcher/DispatcherDocTest.java index 1b3a6e201bd..6ac86a21da3 100644 --- a/akka-docs/src/test/java/jdocs/dispatcher/DispatcherDocTest.java +++ b/akka-docs/src/test/java/jdocs/dispatcher/DispatcherDocTest.java @@ -15,7 +15,6 @@ import jdocs.actor.MyActor; import org.junit.ClassRule; import org.junit.Test; -import scala.concurrent.ExecutionContext; import scala.concurrent.ExecutionContextExecutor; // #imports diff --git a/akka-docs/src/test/java/jdocs/pattern/BackoffSupervisorDocTest.java b/akka-docs/src/test/java/jdocs/pattern/BackoffSupervisorDocTest.java index dc3bf006b15..e1e22fd0476 100644 --- a/akka-docs/src/test/java/jdocs/pattern/BackoffSupervisorDocTest.java +++ b/akka-docs/src/test/java/jdocs/pattern/BackoffSupervisorDocTest.java @@ -5,7 +5,6 @@ package jdocs.pattern; import akka.actor.*; -import akka.pattern.Backoff; import akka.pattern.BackoffOpts; import akka.pattern.BackoffSupervisor; import akka.testkit.TestActors.EchoActor; diff --git a/akka-docs/src/test/java/jdocs/pattern/SupervisedAskSpec.java b/akka-docs/src/test/java/jdocs/pattern/SupervisedAskSpec.java index a10738b39c0..9ecc84019b7 100644 --- a/akka-docs/src/test/java/jdocs/pattern/SupervisedAskSpec.java +++ b/akka-docs/src/test/java/jdocs/pattern/SupervisedAskSpec.java @@ -8,8 +8,6 @@ import akka.actor.ActorRefFactory; import akka.actor.Props; import akka.actor.AbstractActor; -import akka.util.Timeout; -import scala.concurrent.duration.FiniteDuration; import java.time.Duration; import java.util.concurrent.CompletionStage; diff --git a/akka-docs/src/test/java/jdocs/persistence/PersistenceQueryDocTest.java b/akka-docs/src/test/java/jdocs/persistence/PersistenceQueryDocTest.java index 54c058a2e04..6155b918dba 100644 --- a/akka-docs/src/test/java/jdocs/persistence/PersistenceQueryDocTest.java +++ b/akka-docs/src/test/java/jdocs/persistence/PersistenceQueryDocTest.java @@ -10,7 +10,6 @@ import java.util.Set; import akka.NotUsed; -import akka.actor.typed.javadsl.AbstractBehavior; import akka.persistence.query.Sequence; import akka.persistence.query.Offset; import com.typesafe.config.Config; diff --git a/akka-docs/src/test/java/jdocs/persistence/query/MyEventsByTagSource.java b/akka-docs/src/test/java/jdocs/persistence/query/MyEventsByTagSource.java index ab44e5ed0b8..51cdf0dc858 100644 --- a/akka-docs/src/test/java/jdocs/persistence/query/MyEventsByTagSource.java +++ b/akka-docs/src/test/java/jdocs/persistence/query/MyEventsByTagSource.java @@ -5,8 +5,6 @@ package jdocs.persistence.query; import akka.actor.ActorSystem; -import akka.japi.Pair; -import akka.persistence.PersistentRepr; import akka.persistence.query.EventEnvelope; import akka.persistence.query.Offset; import akka.serialization.Serialization; @@ -22,8 +20,6 @@ import java.util.LinkedList; import java.util.List; -import static java.util.stream.Collectors.toList; - // #events-by-tag-publisher public class MyEventsByTagSource extends GraphStage> { public Outlet out = Outlet.create("MyEventByTagSource.out"); diff --git a/akka-docs/src/test/java/jdocs/stream/FlowErrorDocTest.java b/akka-docs/src/test/java/jdocs/stream/FlowErrorDocTest.java index 01546d9400f..b80230bd77b 100644 --- a/akka-docs/src/test/java/jdocs/stream/FlowErrorDocTest.java +++ b/akka-docs/src/test/java/jdocs/stream/FlowErrorDocTest.java @@ -21,7 +21,6 @@ import org.junit.Test; import akka.actor.ActorSystem; -import akka.stream.Materializer; import akka.stream.Supervision; import akka.stream.ActorAttributes; import akka.japi.function.Function; diff --git a/akka-docs/src/test/java/jdocs/stream/FlowParallelismDocTest.java b/akka-docs/src/test/java/jdocs/stream/FlowParallelismDocTest.java index c055df044c2..4b7e0fa0c27 100644 --- a/akka-docs/src/test/java/jdocs/stream/FlowParallelismDocTest.java +++ b/akka-docs/src/test/java/jdocs/stream/FlowParallelismDocTest.java @@ -4,8 +4,6 @@ package jdocs.stream; -import static org.junit.Assert.assertEquals; - import akka.NotUsed; import jdocs.AbstractJavaTest; import akka.testkit.javadsl.TestKit; diff --git a/akka-docs/src/test/java/jdocs/stream/FlowStreamRefsDocTest.java b/akka-docs/src/test/java/jdocs/stream/FlowStreamRefsDocTest.java index a265d03609f..67af1c32a95 100644 --- a/akka-docs/src/test/java/jdocs/stream/FlowStreamRefsDocTest.java +++ b/akka-docs/src/test/java/jdocs/stream/FlowStreamRefsDocTest.java @@ -9,7 +9,6 @@ import akka.actor.ActorRef; import akka.actor.ActorSystem; import akka.actor.Props; -import akka.pattern.Patterns; import akka.stream.*; import akka.stream.javadsl.*; import akka.testkit.javadsl.TestKit; @@ -18,7 +17,6 @@ import scala.concurrent.duration.FiniteDuration; import java.util.concurrent.TimeUnit; -import java.util.concurrent.CompletionStage; public class FlowStreamRefsDocTest extends AbstractJavaTest { diff --git a/akka-docs/src/test/java/jdocs/stream/operators/SinkDocExamples.java b/akka-docs/src/test/java/jdocs/stream/operators/SinkDocExamples.java index 02c5fd984d7..b17d2201de0 100644 --- a/akka-docs/src/test/java/jdocs/stream/operators/SinkDocExamples.java +++ b/akka-docs/src/test/java/jdocs/stream/operators/SinkDocExamples.java @@ -8,7 +8,6 @@ import akka.actor.ActorSystem; import akka.stream.javadsl.AsPublisher; -import akka.stream.javadsl.Flow; import akka.stream.javadsl.Sink; import akka.stream.javadsl.Source; // #takeLast-operator-example @@ -18,8 +17,6 @@ import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletionStage; -import java.util.concurrent.ExecutionException; -import java.util.concurrent.TimeoutException; public class SinkDocExamples { diff --git a/akka-docs/src/test/java/jdocs/stream/operators/SourceOrFlow.java b/akka-docs/src/test/java/jdocs/stream/operators/SourceOrFlow.java index 31e0e63ad6f..e990860166b 100644 --- a/akka-docs/src/test/java/jdocs/stream/operators/SourceOrFlow.java +++ b/akka-docs/src/test/java/jdocs/stream/operators/SourceOrFlow.java @@ -8,7 +8,6 @@ import akka.actor.ActorRef; import akka.actor.ActorSystem; import akka.japi.pf.PFBuilder; -import akka.stream.Materializer; import akka.stream.javadsl.Flow; import akka.NotUsed; @@ -50,10 +49,8 @@ // #log import java.time.Duration; -import java.util.Collection; import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletionStage; -import java.util.function.IntSupplier; class SourceOrFlow { private static ActorSystem system = null; diff --git a/akka-docs/src/test/java/jdocs/stream/operators/flow/FromSinkAndSource.java b/akka-docs/src/test/java/jdocs/stream/operators/flow/FromSinkAndSource.java index 9bfe09f7357..b3e7f7bfac8 100644 --- a/akka-docs/src/test/java/jdocs/stream/operators/flow/FromSinkAndSource.java +++ b/akka-docs/src/test/java/jdocs/stream/operators/flow/FromSinkAndSource.java @@ -12,8 +12,6 @@ import akka.stream.testkit.TestPublisher; import akka.stream.testkit.TestSubscriber; import akka.util.ByteString; -import org.reactivestreams.Publisher; -import org.reactivestreams.Subscriber; import java.time.Duration; import java.util.concurrent.CompletionStage; diff --git a/akka-docs/src/test/java/jdocs/stream/operators/source/Lazy.java b/akka-docs/src/test/java/jdocs/stream/operators/source/Lazy.java index c8bda8ae366..8ad77dbbd3f 100644 --- a/akka-docs/src/test/java/jdocs/stream/operators/source/Lazy.java +++ b/akka-docs/src/test/java/jdocs/stream/operators/source/Lazy.java @@ -4,7 +4,6 @@ package jdocs.stream.operators.source; -import akka.Done; import akka.NotUsed; import akka.actor.ActorSystem; import akka.japi.Pair; diff --git a/akka-docs/src/test/java/jdocs/stream/operators/source/UnfoldAsync.java b/akka-docs/src/test/java/jdocs/stream/operators/source/UnfoldAsync.java index edcb50e2aca..314e5d21d0c 100644 --- a/akka-docs/src/test/java/jdocs/stream/operators/source/UnfoldAsync.java +++ b/akka-docs/src/test/java/jdocs/stream/operators/source/UnfoldAsync.java @@ -10,7 +10,6 @@ import akka.japi.Pair; import akka.stream.javadsl.Source; import akka.util.ByteString; -import akka.util.Timeout; import akka.actor.typed.javadsl.AskPattern; import java.time.Duration; diff --git a/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Monitor.java b/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Monitor.java index 9ca1956b469..f574bee1383 100644 --- a/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Monitor.java +++ b/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Monitor.java @@ -5,7 +5,6 @@ package jdocs.stream.operators.sourceorflow; import akka.Done; -import akka.NotUsed; import akka.actor.ActorSystem; import akka.japi.Pair; import akka.stream.FlowMonitor; @@ -18,7 +17,6 @@ import java.util.Arrays; import java.util.concurrent.CompletionStage; import java.util.concurrent.ExecutionException; -import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; /** */ diff --git a/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Sliding.java b/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Sliding.java index c227cb557f4..df8a17569c6 100644 --- a/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Sliding.java +++ b/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Sliding.java @@ -9,7 +9,6 @@ import akka.stream.javadsl.Source; import java.util.Arrays; -import java.util.stream.Collectors; public class Sliding { diff --git a/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Split.java b/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Split.java index e64b9a5bc8e..b2de4c2acb9 100644 --- a/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Split.java +++ b/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Split.java @@ -6,7 +6,6 @@ import akka.actor.ActorSystem; import akka.japi.Pair; -import akka.japi.function.Creator; import akka.japi.function.Function; import akka.stream.javadsl.Sink; import akka.stream.javadsl.Source; diff --git a/akka-docs/src/test/java/jdocs/typed/tutorial_5/DeviceTest.java b/akka-docs/src/test/java/jdocs/typed/tutorial_5/DeviceTest.java index 63fedb97c42..176060ca6f4 100644 --- a/akka-docs/src/test/java/jdocs/typed/tutorial_5/DeviceTest.java +++ b/akka-docs/src/test/java/jdocs/typed/tutorial_5/DeviceTest.java @@ -14,7 +14,6 @@ import java.util.Optional; import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertNotEquals; public class DeviceTest extends JUnitSuite { diff --git a/akka-persistence-query/src/test/java/akka/persistence/query/PersistenceQueryTest.java b/akka-persistence-query/src/test/java/akka/persistence/query/PersistenceQueryTest.java index 3561165fd1c..93a8e34614b 100644 --- a/akka-persistence-query/src/test/java/akka/persistence/query/PersistenceQueryTest.java +++ b/akka-persistence-query/src/test/java/akka/persistence/query/PersistenceQueryTest.java @@ -7,7 +7,6 @@ import akka.NotUsed; import akka.actor.ActorSystem; import akka.testkit.AkkaJUnitActorSystemResource; -import com.typesafe.config.ConfigFactory; import org.junit.ClassRule; public class PersistenceQueryTest { diff --git a/akka-persistence-typed/src/test/java/akka/persistence/typed/javadsl/PersistentActorJavaDslTest.java b/akka-persistence-typed/src/test/java/akka/persistence/typed/javadsl/PersistentActorJavaDslTest.java index 1045a5ab0fc..98a407e9675 100644 --- a/akka-persistence-typed/src/test/java/akka/persistence/typed/javadsl/PersistentActorJavaDslTest.java +++ b/akka-persistence-typed/src/test/java/akka/persistence/typed/javadsl/PersistentActorJavaDslTest.java @@ -26,7 +26,6 @@ import com.fasterxml.jackson.annotation.JsonCreator; import com.fasterxml.jackson.annotation.JsonSubTypes; import com.fasterxml.jackson.annotation.JsonTypeInfo; -import com.google.common.collect.Lists; import com.google.common.collect.Sets; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; diff --git a/akka-stream-tests/src/test/java/akka/stream/io/InputStreamSinkTest.java b/akka-stream-tests/src/test/java/akka/stream/io/InputStreamSinkTest.java index 5b23ce6314d..b93c7386055 100644 --- a/akka-stream-tests/src/test/java/akka/stream/io/InputStreamSinkTest.java +++ b/akka-stream-tests/src/test/java/akka/stream/io/InputStreamSinkTest.java @@ -4,25 +4,21 @@ package akka.stream.io; -import akka.japi.Pair; import akka.stream.StreamTest; import akka.testkit.AkkaJUnitActorSystemResource; import akka.stream.javadsl.Sink; import akka.stream.javadsl.Source; import akka.stream.javadsl.StreamConverters; -import akka.testkit.AkkaSpec; import akka.stream.testkit.Utils; import akka.util.ByteString; import org.junit.ClassRule; import org.junit.Test; -import scala.concurrent.Future; import java.io.InputStream; import java.time.Duration; import java.util.Arrays; import java.util.Collections; import java.util.List; -import java.util.concurrent.TimeUnit; import static org.junit.Assert.assertTrue; diff --git a/akka-stream-tests/src/test/java/akka/stream/javadsl/FlowTest.java b/akka-stream-tests/src/test/java/akka/stream/javadsl/FlowTest.java index f4c8eb908a7..c9ab2ede247 100644 --- a/akka-stream-tests/src/test/java/akka/stream/javadsl/FlowTest.java +++ b/akka-stream-tests/src/test/java/akka/stream/javadsl/FlowTest.java @@ -24,7 +24,6 @@ import org.junit.Test; import org.reactivestreams.Publisher; import akka.testkit.AkkaJUnitActorSystemResource; -import scala.Tuple2; import java.util.*; import java.util.function.Supplier; diff --git a/akka-stream-tests/src/test/java/akka/stream/javadsl/LazyAndFutureFlowTest.java b/akka-stream-tests/src/test/java/akka/stream/javadsl/LazyAndFutureFlowTest.java index 2a58ef1201d..cb1c4a0bbad 100644 --- a/akka-stream-tests/src/test/java/akka/stream/javadsl/LazyAndFutureFlowTest.java +++ b/akka-stream-tests/src/test/java/akka/stream/javadsl/LazyAndFutureFlowTest.java @@ -4,7 +4,6 @@ package akka.stream.javadsl; -import akka.NotUsed; import akka.stream.StreamTest; import akka.testkit.AkkaJUnitActorSystemResource; import akka.testkit.AkkaSpec; diff --git a/akka-stream-tests/src/test/java/akka/stream/javadsl/RetryFlowTest.java b/akka-stream-tests/src/test/java/akka/stream/javadsl/RetryFlowTest.java index 09148b0fb01..9d2fe94d3b0 100644 --- a/akka-stream-tests/src/test/java/akka/stream/javadsl/RetryFlowTest.java +++ b/akka-stream-tests/src/test/java/akka/stream/javadsl/RetryFlowTest.java @@ -22,7 +22,6 @@ import java.time.Duration; import java.util.Optional; -import static akka.NotUsed.notUsed; import static org.junit.Assert.assertEquals; public class RetryFlowTest extends StreamTest { diff --git a/akka-stream-typed/src/test/java/akka/stream/typed/javadsl/ActorSourceSinkCompileTest.java b/akka-stream-typed/src/test/java/akka/stream/typed/javadsl/ActorSourceSinkCompileTest.java index d11f7354846..2bbaf1ef932 100644 --- a/akka-stream-typed/src/test/java/akka/stream/typed/javadsl/ActorSourceSinkCompileTest.java +++ b/akka-stream-typed/src/test/java/akka/stream/typed/javadsl/ActorSourceSinkCompileTest.java @@ -6,7 +6,6 @@ import akka.actor.typed.ActorRef; import akka.actor.typed.ActorSystem; -import akka.japi.JavaPartialFunction; import akka.stream.OverflowStrategy; import akka.stream.javadsl.Sink; import akka.stream.javadsl.Source; diff --git a/akka-testkit/src/test/java/akka/testkit/javadsl/TestKitApiTest.java b/akka-testkit/src/test/java/akka/testkit/javadsl/TestKitApiTest.java index 0ef2d3ffd78..7ac11567fe0 100644 --- a/akka-testkit/src/test/java/akka/testkit/javadsl/TestKitApiTest.java +++ b/akka-testkit/src/test/java/akka/testkit/javadsl/TestKitApiTest.java @@ -11,7 +11,6 @@ import akka.testkit.TestActor; import java.time.Duration; -import java.util.Arrays; import java.util.List; public class TestKitApiTest {