Remove unused imports in tests (#30265)

akka · Jun 1, 2021 · 258bac4 · 258bac4
1 parent a887c63
commit 258bac4
Show file tree

Hide file tree

Showing 42 changed files with 0 additions and 66 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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/...-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/ActorContextPipeToSelfTest.java b/...-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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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<SourceShape<EventEnvelope>> {
   public Outlet<EventEnvelope> 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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/...stence-typed/src/test/java/akka/persistence/typed/javadsl/PersistentActorJavaDslTest.java b/...stence-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
@@ -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
@@ -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
@@ -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
@@ -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 {