diff --git a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/BehaviorSpec.scala b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/BehaviorSpec.scala index 7c83e7ff9e..f3208f062b 100644 --- a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/BehaviorSpec.scala +++ b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/BehaviorSpec.scala @@ -273,8 +273,6 @@ object BehaviorSpec { } trait Become extends Common with Unhandled { - private implicit val inbox = TestInbox[State]("state") - "Becoming" must { "must be in state A" in { mkCtx().check(GetState()(StateA)) diff --git a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/OrElseSpec.scala b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/OrElseSpec.scala index 196acb0788..9bacbda5fb 100644 --- a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/OrElseSpec.scala +++ b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/OrElseSpec.scala @@ -4,10 +4,7 @@ package akka.actor.typed -import scala.util.control.NoStackTrace - import akka.actor.typed.scaladsl.Behaviors -import akka.actor.testkit.typed.TestKitSettings import akka.actor.testkit.typed.scaladsl._ import org.scalatest.WordSpecLike diff --git a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/MessageAdapterSpec.scala b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/MessageAdapterSpec.scala index ebc9339b22..91ec9d9cb3 100644 --- a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/MessageAdapterSpec.scala +++ b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/MessageAdapterSpec.scala @@ -9,7 +9,6 @@ import akka.actor.typed.ActorRef import akka.actor.typed.Behavior import akka.actor.typed.PostStop import akka.actor.typed.Props -import akka.actor.typed.SupervisorStrategy import akka.actor.typed.TestException import akka.actor.typed.TypedAkkaSpecWithShutdown import akka.testkit.EventFilter diff --git a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/StopSpec.scala b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/StopSpec.scala index 91cb15f1b6..8e08523d21 100644 --- a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/StopSpec.scala +++ b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/StopSpec.scala @@ -6,9 +6,8 @@ package akka.actor.typed.scaladsl import akka.Done import akka.actor.testkit.typed.TE -import akka.actor.testkit.typed.scaladsl.{ ActorTestKit, TestProbe } -import akka.actor.typed.{ Behavior, PostStop, SupervisorStrategy, Terminated, TypedAkkaSpecWithShutdown } -import akka.testkit.EventFilter +import akka.actor.testkit.typed.scaladsl.ActorTestKit +import akka.actor.typed.{ PostStop, TypedAkkaSpecWithShutdown } import scala.concurrent.Promise diff --git a/akka-actor-typed/src/main/scala/akka/actor/typed/SupervisorStrategy.scala b/akka-actor-typed/src/main/scala/akka/actor/typed/SupervisorStrategy.scala index 2948ac4416..9d52c7a200 100644 --- a/akka-actor-typed/src/main/scala/akka/actor/typed/SupervisorStrategy.scala +++ b/akka-actor-typed/src/main/scala/akka/actor/typed/SupervisorStrategy.scala @@ -4,8 +4,6 @@ package akka.actor.typed -import java.time - import akka.annotation.InternalApi import scala.concurrent.duration.FiniteDuration import scala.concurrent.duration.Duration diff --git a/akka-actor-typed/src/main/scala/akka/actor/typed/internal/Restarter.scala b/akka-actor-typed/src/main/scala/akka/actor/typed/internal/Restarter.scala index 725f9768a9..2785b0fef0 100644 --- a/akka-actor-typed/src/main/scala/akka/actor/typed/internal/Restarter.scala +++ b/akka-actor-typed/src/main/scala/akka/actor/typed/internal/Restarter.scala @@ -13,7 +13,6 @@ import akka.actor.typed.scaladsl.Behaviors import akka.annotation.InternalApi import akka.util.{ OptionVal, PrettyDuration } -import scala.annotation.tailrec import scala.concurrent.duration.{ Deadline, FiniteDuration } import scala.reflect.ClassTag import scala.util.control.Exception.Catcher diff --git a/akka-actor-typed/src/main/scala/akka/actor/typed/internal/StashBufferImpl.scala b/akka-actor-typed/src/main/scala/akka/actor/typed/internal/StashBufferImpl.scala index 3ec6aa908b..a15334130d 100644 --- a/akka-actor-typed/src/main/scala/akka/actor/typed/internal/StashBufferImpl.scala +++ b/akka-actor-typed/src/main/scala/akka/actor/typed/internal/StashBufferImpl.scala @@ -7,7 +7,6 @@ package akka.actor.typed.internal import java.util.function.Consumer import java.util.function.{ Function ⇒ JFunction } -import akka.actor.typed.ActorContext import akka.actor.typed.Behavior import akka.actor.typed.javadsl import akka.actor.typed.scaladsl diff --git a/akka-actor-typed/src/main/scala/akka/actor/typed/internal/adapter/ActorAdapter.scala b/akka-actor-typed/src/main/scala/akka/actor/typed/internal/adapter/ActorAdapter.scala index c422bc895e..970c6f56f7 100644 --- a/akka-actor-typed/src/main/scala/akka/actor/typed/internal/adapter/ActorAdapter.scala +++ b/akka-actor-typed/src/main/scala/akka/actor/typed/internal/adapter/ActorAdapter.scala @@ -14,7 +14,6 @@ import scala.util.Try import akka.{ actor ⇒ a } import akka.annotation.InternalApi import akka.util.OptionVal -import scala.util.control.NonFatal /** * INTERNAL API diff --git a/akka-remote/src/main/scala/akka/remote/artery/ImmutableLongMap.scala b/akka-remote/src/main/scala/akka/remote/artery/ImmutableLongMap.scala index a8363ee30a..3b252da521 100644 --- a/akka-remote/src/main/scala/akka/remote/artery/ImmutableLongMap.scala +++ b/akka-remote/src/main/scala/akka/remote/artery/ImmutableLongMap.scala @@ -16,8 +16,6 @@ import akka.util.HashCode private[akka] object ImmutableLongMap { def empty[A >: Null](implicit t: ClassTag[A]): ImmutableLongMap[A] = new ImmutableLongMap(Array.emptyLongArray, Array.empty) - - private val MaxScanLength = 10 } /** diff --git a/akka-remote/src/main/scala/akka/remote/transport/netty/SSLEngineProvider.scala b/akka-remote/src/main/scala/akka/remote/transport/netty/SSLEngineProvider.scala index 8b396367cb..ec9e2f5d82 100644 --- a/akka-remote/src/main/scala/akka/remote/transport/netty/SSLEngineProvider.scala +++ b/akka-remote/src/main/scala/akka/remote/transport/netty/SSLEngineProvider.scala @@ -12,32 +12,21 @@ import java.security.GeneralSecurityException import java.security.KeyStore import java.security.SecureRandom -import scala.annotation.tailrec import scala.util.Try import akka.actor.ActorSystem -import akka.actor.ExtendedActorSystem import akka.annotation.ApiMayChange -import akka.event.LogMarker import akka.event.Logging import akka.event.MarkerLoggingAdapter -import akka.japi.Util.immutableSeq -import akka.remote.RemoteTransport -import akka.remote.RemoteActorRefProvider import akka.remote.RemoteTransportException import akka.remote.artery.tcp.SecureRandomFactory -import akka.remote.security.provider.AkkaProvider -import akka.remote.transport.AbstractTransportAdapter import akka.stream.IgnoreComplete import akka.stream.TLSClosing import akka.stream.TLSRole -import com.typesafe.config.Config -import com.typesafe.sslconfig.ssl.SSLConfigSettings import javax.net.ssl.KeyManager import javax.net.ssl.KeyManagerFactory import javax.net.ssl.SSLContext import javax.net.ssl.SSLEngine -import javax.net.ssl.SSLSession import javax.net.ssl.TrustManager import javax.net.ssl.TrustManagerFactory diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/Graph.scala b/akka-stream/src/main/scala/akka/stream/javadsl/Graph.scala index 1ff26448b7..5eec2f66d7 100644 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Graph.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Graph.scala @@ -13,11 +13,7 @@ import akka.util.ConstantFun import scala.annotation.unchecked.uncheckedVariance import scala.collection.JavaConverters._ -import akka.stream.scaladsl.{ GenericGraph, GenericGraphWithChangedAttributes } -import akka.stream.Attributes -import akka.stream.impl.TraversalBuilder - -import scala.collection.parallel.immutable +import akka.stream.scaladsl.GenericGraph /** * Merge several streams, taking elements as they arrive from input streams