diff --git a/.scalafix.conf b/.scalafix.conf index e7e05d6f75..21d1adb27d 100644 --- a/.scalafix.conf +++ b/.scalafix.conf @@ -1,9 +1,14 @@ // .scalafix.conf rules = [ RemoveUnused + ExplicitResultTypes "github:ohze/scalafix-rules/ConstructorProcedureSyntax" "github:ohze/scalafix-rules/FinalObject" ] +ExplicitResultTypes { + memberVisibility = [] # only rewrite implicit members + skipSimpleDefinitions = [] +} RemoveUnused.imports = true RemoveUnused.privates = false RemoveUnused.locals = false diff --git a/akka-actor-tests/src/test/scala/akka/actor/ForwardActorSpec.scala b/akka-actor-tests/src/test/scala/akka/actor/ForwardActorSpec.scala index f2cd2bd4e5..207bd40565 100644 --- a/akka-actor-tests/src/test/scala/akka/actor/ForwardActorSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/actor/ForwardActorSpec.scala @@ -9,6 +9,7 @@ import language.postfixOps import akka.testkit._ import scala.concurrent.duration._ import akka.pattern.{ ask, pipe } +import scala.concurrent.ExecutionContextExecutor object ForwardActorSpec { val ExpectedMessage = "FOO" @@ -29,7 +30,7 @@ object ForwardActorSpec { class ForwardActorSpec extends AkkaSpec { import ForwardActorSpec._ - implicit val ec = system.dispatcher + implicit val ec: ExecutionContextExecutor = system.dispatcher "A Forward Actor" must { "forward actor reference when invoking forward on tell" in { diff --git a/akka-actor-tests/src/test/scala/akka/dataflow/Future2Actor.scala b/akka-actor-tests/src/test/scala/akka/dataflow/Future2Actor.scala index 30509e2e59..5f5cb53ea4 100644 --- a/akka-actor-tests/src/test/scala/akka/dataflow/Future2Actor.scala +++ b/akka-actor-tests/src/test/scala/akka/dataflow/Future2Actor.scala @@ -13,9 +13,10 @@ import scala.concurrent.duration._ import akka.testkit.{ AkkaSpec, DefaultTimeout } import akka.pattern.{ ask, pipe } import scala.concurrent.ExecutionException +import scala.concurrent.ExecutionContextExecutor class Future2ActorSpec extends AkkaSpec with DefaultTimeout { - implicit val ec = system.dispatcher + implicit val ec: ExecutionContextExecutor = system.dispatcher "The Future2Actor bridge" must { "support convenient sending to multiple destinations" in { diff --git a/akka-actor-tests/src/test/scala/akka/io/dns/AsyncDnsResolverIntegrationSpec.scala b/akka-actor-tests/src/test/scala/akka/io/dns/AsyncDnsResolverIntegrationSpec.scala index dbdb8115c2..9a524ff946 100644 --- a/akka-actor-tests/src/test/scala/akka/io/dns/AsyncDnsResolverIntegrationSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/io/dns/AsyncDnsResolverIntegrationSpec.scala @@ -33,7 +33,7 @@ class AsyncDnsResolverIntegrationSpec extends AkkaSpec(s""" akka.io.dns.async-dns.ndots = 2 """) with DockerBindDnsService with WithLogCapturing { val duration = 10.seconds - implicit val timeout = Timeout(duration) + implicit val timeout: Timeout = Timeout(duration) val hostPort = AsyncDnsResolverIntegrationSpec.dockerDnsServerPort diff --git a/akka-actor-tests/src/test/scala/akka/io/dns/internal/AsyncDnsResolverSpec.scala b/akka-actor-tests/src/test/scala/akka/io/dns/internal/AsyncDnsResolverSpec.scala index 2ffa61f4e4..3e7f6afc10 100644 --- a/akka-actor-tests/src/test/scala/akka/io/dns/internal/AsyncDnsResolverSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/io/dns/internal/AsyncDnsResolverSpec.scala @@ -39,7 +39,7 @@ class AsyncDnsResolverSpec extends AkkaSpec(""" val dnsClient2 = TestProbe() val r = resolver(List(dnsClient1.ref, dnsClient2.ref), defaultConfig) val senderProbe = TestProbe() - implicit val sender = senderProbe.ref + implicit val sender: ActorRef = senderProbe.ref } "Async DNS Resolver" must { diff --git a/akka-actor-tests/src/test/scala/akka/pattern/CircuitBreakerMTSpec.scala b/akka-actor-tests/src/test/scala/akka/pattern/CircuitBreakerMTSpec.scala index 06ca663c92..9d48b7b3b4 100644 --- a/akka-actor-tests/src/test/scala/akka/pattern/CircuitBreakerMTSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/pattern/CircuitBreakerMTSpec.scala @@ -8,9 +8,10 @@ import akka.testkit._ import scala.collection.immutable import scala.concurrent.duration._ import scala.concurrent.{ Await, Future } +import scala.concurrent.ExecutionContextExecutor class CircuitBreakerMTSpec extends AkkaSpec { - implicit val ec = system.dispatcher + implicit val ec: ExecutionContextExecutor = system.dispatcher "A circuit breaker being called by many threads" must { val callTimeout = 2.second.dilated val resetTimeout = 3.seconds.dilated diff --git a/akka-actor-tests/src/test/scala/akka/pattern/CircuitBreakerSpec.scala b/akka-actor-tests/src/test/scala/akka/pattern/CircuitBreakerSpec.scala index ed76e6351a..736c87e8dc 100644 --- a/akka-actor-tests/src/test/scala/akka/pattern/CircuitBreakerSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/pattern/CircuitBreakerSpec.scala @@ -16,6 +16,7 @@ import scala.language.postfixOps import scala.util.Failure import scala.util.Success import scala.util.Try +import scala.concurrent.ExecutionContextExecutor object CircuitBreakerSpec { @@ -83,7 +84,7 @@ object CircuitBreakerSpec { class CircuitBreakerSpec extends AkkaSpec { import CircuitBreakerSpec._ - implicit def ec = system.dispatcher + implicit def ec: ExecutionContextExecutor = system.dispatcher val awaitTimeout = 2.seconds.dilated diff --git a/akka-actor-tests/src/test/scala/akka/pattern/PatternSpec.scala b/akka-actor-tests/src/test/scala/akka/pattern/PatternSpec.scala index f8beece227..ccd298f143 100644 --- a/akka-actor-tests/src/test/scala/akka/pattern/PatternSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/pattern/PatternSpec.scala @@ -10,6 +10,7 @@ import akka.testkit.{ AkkaSpec, TestLatch } import akka.actor.{ Actor, Props } import scala.concurrent.{ Await, Future, Promise } import scala.concurrent.duration._ +import scala.concurrent.ExecutionContextExecutor object PatternSpec { final case class Work(duration: Duration) @@ -22,7 +23,7 @@ object PatternSpec { } class PatternSpec extends AkkaSpec { - implicit val ec = system.dispatcher + implicit val ec: ExecutionContextExecutor = system.dispatcher import PatternSpec._ "pattern.gracefulStop" must { diff --git a/akka-actor-tests/src/test/scala/akka/routing/ConsistentHashingRouterSpec.scala b/akka-actor-tests/src/test/scala/akka/routing/ConsistentHashingRouterSpec.scala index 0b927d6658..d293e7cb29 100644 --- a/akka-actor-tests/src/test/scala/akka/routing/ConsistentHashingRouterSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/routing/ConsistentHashingRouterSpec.scala @@ -14,6 +14,7 @@ import akka.routing.ConsistentHashingRouter.ConsistentHashableEnvelope import akka.routing.ConsistentHashingRouter.ConsistentHashMapping import akka.testkit.AkkaSpec import akka.testkit._ +import scala.concurrent.ExecutionContextExecutor object ConsistentHashingRouterSpec { @@ -56,7 +57,7 @@ class ConsistentHashingRouterSpec with DefaultTimeout with ImplicitSender { import ConsistentHashingRouterSpec._ - implicit val ec = system.dispatcher + implicit val ec: ExecutionContextExecutor = system.dispatcher val router1 = system.actorOf(FromConfig.props(Props[Echo]), "router1") diff --git a/akka-actor-tests/src/test/scala/akka/routing/RoutingSpec.scala b/akka-actor-tests/src/test/scala/akka/routing/RoutingSpec.scala index 40664d06b8..b37ca3bbd6 100644 --- a/akka-actor-tests/src/test/scala/akka/routing/RoutingSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/routing/RoutingSpec.scala @@ -14,6 +14,7 @@ import scala.concurrent.Await import akka.ConfigurationException import com.typesafe.config.ConfigFactory import akka.pattern.{ ask, pipe } +import scala.concurrent.ExecutionContextExecutor object RoutingSpec { @@ -47,7 +48,7 @@ object RoutingSpec { } class RoutingSpec extends AkkaSpec(RoutingSpec.config) with DefaultTimeout with ImplicitSender { - implicit val ec = system.dispatcher + implicit val ec: ExecutionContextExecutor = system.dispatcher import RoutingSpec._ muteDeadLetters(classOf[akka.dispatch.sysmsg.DeathWatchNotification])(system) diff --git a/akka-actor-tests/src/test/scala/akka/serialization/SerializeSpec.scala b/akka-actor-tests/src/test/scala/akka/serialization/SerializeSpec.scala index 5a39791212..f53f3795d3 100644 --- a/akka-actor-tests/src/test/scala/akka/serialization/SerializeSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/serialization/SerializeSpec.scala @@ -276,7 +276,7 @@ class SerializeSpec extends AkkaSpec(SerializationTests.serializeConf) { } class VerifySerializabilitySpec extends AkkaSpec(SerializationTests.verifySerializabilityConf) { - implicit val timeout = Timeout(5 seconds) + implicit val timeout: Timeout = Timeout(5 seconds) "verify config" in { system.settings.SerializeAllCreators should ===(true) diff --git a/akka-actor-tests/src/test/scala/akka/util/ByteStringSpec.scala b/akka-actor-tests/src/test/scala/akka/util/ByteStringSpec.scala index ac3fc8a16c..5977403ac2 100644 --- a/akka-actor-tests/src/test/scala/akka/util/ByteStringSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/util/ByteStringSpec.scala @@ -23,7 +23,8 @@ import scala.collection.mutable.Builder class ByteStringSpec extends AnyWordSpec with Matchers with Checkers { - implicit val betterGeneratorDrivenConfig = PropertyCheckConfiguration().copy(minSuccessful = 1000) + implicit val betterGeneratorDrivenConfig: PropertyCheckConfiguration = + PropertyCheckConfiguration().copy(minSuccessful = 1000) def genSimpleByteString(min: Int, max: Int) = for { @@ -57,7 +58,7 @@ class ByteStringSpec extends AnyWordSpec with Matchers with Checkers { case class ByteStringGrouped(bs: ByteString, size: Int) - implicit val arbitraryByteStringGrouped = Arbitrary { + implicit val arbitraryByteStringGrouped: Arbitrary[ByteStringGrouped] = Arbitrary { for { xs <- arbitraryByteString.arbitrary size <- Gen.choose(1, 1 max xs.length) diff --git a/akka-actor-tests/src/test/scala/akka/util/IndexSpec.scala b/akka-actor-tests/src/test/scala/akka/util/IndexSpec.scala index 35e626f35e..cad784c348 100644 --- a/akka-actor-tests/src/test/scala/akka/util/IndexSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/util/IndexSpec.scala @@ -11,9 +11,10 @@ import scala.concurrent.Await import scala.util.Random import akka.testkit.DefaultTimeout import org.scalatest.matchers.should.Matchers +import scala.concurrent.ExecutionContextExecutor class IndexSpec extends AkkaSpec with Matchers with DefaultTimeout { - implicit val ec = system.dispatcher + implicit val ec: ExecutionContextExecutor = system.dispatcher private def emptyIndex = new Index[String, Int](100, new Comparator[Int] { override def compare(a: Int, b: Int): Int = Integer.compare(a, b) diff --git a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/DeferredSpec.scala b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/DeferredSpec.scala index db0bf89418..55070c98d7 100644 --- a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/DeferredSpec.scala +++ b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/DeferredSpec.scala @@ -34,7 +34,7 @@ object DeferredSpec { class DeferredSpec extends ScalaTestWithActorTestKit with AnyWordSpecLike with LogCapturing { import DeferredSpec._ - implicit val testSettings = TestKitSettings(system) + implicit val testSettings: TestKitSettings = TestKitSettings(system) "Deferred behavior" must { "must create underlying" in { diff --git a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/SpawnProtocolSpec.scala b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/SpawnProtocolSpec.scala index fec98eaa65..41b966d5df 100644 --- a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/SpawnProtocolSpec.scala +++ b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/SpawnProtocolSpec.scala @@ -30,7 +30,7 @@ object SpawnProtocolSpec { class SpawnProtocolSpec extends ScalaTestWithActorTestKit with AnyWordSpecLike with LogCapturing { import SpawnProtocolSpec._ - implicit val testSettings = TestKitSettings(system) + implicit val testSettings: TestKitSettings = TestKitSettings(system) "Spawn behavior" must { "spawn child actor" in { diff --git a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/TransformMessagesSpec.scala b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/TransformMessagesSpec.scala index beba7444d7..9af30609d0 100644 --- a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/TransformMessagesSpec.scala +++ b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/TransformMessagesSpec.scala @@ -16,6 +16,7 @@ import scala.concurrent.duration._ import akka.actor.testkit.typed.scaladsl.LoggingTestKit import akka.actor.testkit.typed.scaladsl.LogCapturing import org.scalatest.wordspec.AnyWordSpecLike +import akka.actor object TransformMessagesSpec { @@ -35,7 +36,7 @@ object TransformMessagesSpec { class TransformMessagesSpec extends ScalaTestWithActorTestKit with AnyWordSpecLike with LogCapturing { - implicit val classicSystem = system.toClassic + implicit val classicSystem: actor.ActorSystem = system.toClassic def intToString(probe: ActorRef[String]): Behavior[Int] = { Behaviors diff --git a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/WatchSpec.scala b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/WatchSpec.scala index da398bb037..d2960095b9 100644 --- a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/WatchSpec.scala +++ b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/WatchSpec.scala @@ -17,6 +17,7 @@ import akka.actor.testkit.typed.scaladsl.LoggingTestKit import akka.actor.testkit.typed.scaladsl.ScalaTestWithActorTestKit import akka.actor.testkit.typed.scaladsl.LogCapturing import org.scalatest.wordspec.AnyWordSpecLike +import akka.actor object WatchSpec { @@ -45,7 +46,7 @@ object WatchSpec { class WatchSpec extends ScalaTestWithActorTestKit with AnyWordSpecLike with LogCapturing { - implicit def classicSystem = system.toClassic + implicit def classicSystem: actor.ActorSystem = system.toClassic import WatchSpec._ diff --git a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/coexistence/ClassicSupervisingTypedSpec.scala b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/coexistence/ClassicSupervisingTypedSpec.scala index a7aed5982a..818785b33f 100644 --- a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/coexistence/ClassicSupervisingTypedSpec.scala +++ b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/coexistence/ClassicSupervisingTypedSpec.scala @@ -56,7 +56,7 @@ class ClassicSupervisingTypedSpec extends AnyWordSpecLike with LogCapturing with akka.actor.testkit.typed.expect-no-message-default = 50 ms """)) val classicTestKit = new akka.testkit.TestKit(classicSystem) - implicit val classicSender = classicTestKit.testActor + implicit val classicSender: u.ActorRef = classicTestKit.testActor import classicTestKit._ "A classic actor system that spawns typed actors" should { diff --git a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/internal/ActorSystemSpec.scala b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/internal/ActorSystemSpec.scala index ee7e359757..ee90e38b75 100644 --- a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/internal/ActorSystemSpec.scala +++ b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/internal/ActorSystemSpec.scala @@ -28,7 +28,7 @@ class ActorSystemSpec with Eventually with LogCapturing { - override implicit val patienceConfig = PatienceConfig(1.second) + override implicit val patienceConfig: PatienceConfig = PatienceConfig(1.second) def system[T](behavior: Behavior[T], name: String) = ActorSystem(behavior, name) def suite = "adapter" diff --git a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/ActorLoggingSpec.scala b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/ActorLoggingSpec.scala index be88570067..b62d77e55c 100644 --- a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/ActorLoggingSpec.scala +++ b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/ActorLoggingSpec.scala @@ -28,6 +28,7 @@ import org.slf4j.LoggerFactory import org.slf4j.MDC import org.slf4j.helpers.BasicMarkerFactory import org.scalatest.wordspec.AnyWordSpecLike +import akka.actor.ActorSystem class SomeClass @@ -57,7 +58,7 @@ class ActorLoggingSpec extends ScalaTestWithActorTestKit(""" val marker = new BasicMarkerFactory().getMarker("marker") val cause = TestException("böö") - implicit val classic = system.toClassic + implicit val classic: ActorSystem = system.toClassic class AnotherLoggerClass diff --git a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/ReceivePartialSpec.scala b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/ReceivePartialSpec.scala index cb4fe4b9ec..7bc2896b8f 100644 --- a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/ReceivePartialSpec.scala +++ b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/ReceivePartialSpec.scala @@ -9,10 +9,11 @@ import akka.actor.testkit.typed.scaladsl.ScalaTestWithActorTestKit import akka.actor.testkit.typed.scaladsl.TestProbe import akka.actor.testkit.typed.scaladsl.LogCapturing import org.scalatest.wordspec.AnyWordSpecLike +import scala.concurrent.ExecutionContextExecutor class ReceivePartialSpec extends ScalaTestWithActorTestKit with AnyWordSpecLike with LogCapturing { - implicit val ec = system.executionContext + implicit val ec: ExecutionContextExecutor = system.executionContext "An immutable partial" must { "correctly install the receiveMessage handler" in { diff --git a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/adapter/AdapterSpec.scala b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/adapter/AdapterSpec.scala index 0064d8760d..04c579c75b 100644 --- a/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/adapter/AdapterSpec.scala +++ b/akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/adapter/AdapterSpec.scala @@ -184,7 +184,7 @@ object AdapterSpec { class AdapterSpec extends AnyWordSpec with Matchers with BeforeAndAfterAll with LogCapturing { import AdapterSpec._ - implicit val system = akka.actor.ActorSystem("AdapterSpec") + implicit val system: classic.ActorSystem = akka.actor.ActorSystem("AdapterSpec") def typedSystem: ActorSystem[Nothing] = system.toTyped "ActorSystem adaption" must { diff --git a/akka-actor/src/main/scala/akka/actor/Actor.scala b/akka-actor/src/main/scala/akka/actor/Actor.scala index 18c6001a78..141adfd082 100644 --- a/akka-actor/src/main/scala/akka/actor/Actor.scala +++ b/akka-actor/src/main/scala/akka/actor/Actor.scala @@ -500,7 +500,7 @@ trait Actor { * self ! message * */ - implicit final val self = context.self //MUST BE A VAL, TRUST ME + implicit final val self: ActorRef = context.self //MUST BE A VAL, TRUST ME /** * The reference sender Actor of the last received message. diff --git a/akka-actor/src/main/scala/akka/actor/FSM.scala b/akka-actor/src/main/scala/akka/actor/FSM.scala index c21daab440..e8842f1ca9 100644 --- a/akka-actor/src/main/scala/akka/actor/FSM.scala +++ b/akka-actor/src/main/scala/akka/actor/FSM.scala @@ -13,6 +13,7 @@ import akka.routing.{ Deafen, Listen, Listeners } import akka.annotation.InternalApi import akka.util.{ unused, JavaDurationConverters } import com.github.ghik.silencer.silent +import scala.concurrent.ExecutionContextExecutor object FSM { @@ -121,7 +122,7 @@ object FSM { extends NoSerializationVerificationNeeded { private var ref: Option[Cancellable] = _ private val scheduler = context.system.scheduler - private implicit val executionContext = context.dispatcher + private implicit val executionContext: ExecutionContextExecutor = context.dispatcher def schedule(actor: ActorRef, timeout: FiniteDuration): Unit = { val timerMsg = msg match { diff --git a/akka-actor/src/main/scala/akka/actor/TypedActor.scala b/akka-actor/src/main/scala/akka/actor/TypedActor.scala index b39689c9f6..e0dd151848 100644 --- a/akka-actor/src/main/scala/akka/actor/TypedActor.scala +++ b/akka-actor/src/main/scala/akka/actor/TypedActor.scala @@ -24,6 +24,7 @@ import java.io.ObjectStreamException import java.lang.reflect.{ InvocationHandler, InvocationTargetException, Method, Proxy } import com.github.ghik.silencer.silent +import scala.concurrent.ExecutionContextExecutor /** * A TypedActorFactory is something that can created TypedActor instances. @@ -252,7 +253,7 @@ object TypedActor extends ExtensionId[TypedActorExtension] with ExtensionIdProvi /** * Returns the default dispatcher (for a TypedActor) when inside a method call in a TypedActor. */ - implicit def dispatcher = context.dispatcher + implicit def dispatcher: ExecutionContextExecutor = context.dispatcher /** * INTERNAL API diff --git a/akka-actor/src/main/scala/akka/event/EventStream.scala b/akka-actor/src/main/scala/akka/event/EventStream.scala index f053563353..456ec8483f 100644 --- a/akka-actor/src/main/scala/akka/event/EventStream.scala +++ b/akka-actor/src/main/scala/akka/event/EventStream.scala @@ -32,7 +32,7 @@ class EventStream(sys: ActorSystem, private val debug: Boolean) extends LoggingB /** Either the list of subscribed actors, or a ref to an [[akka.event.EventStreamUnsubscriber]] */ private val initiallySubscribedOrUnsubscriber = new AtomicReference[Either[Set[ActorRef], ActorRef]](Left(Set.empty)) - protected implicit val subclassification = new Subclassification[Class[_]] { + protected implicit val subclassification: Subclassification[Classifier] = new Subclassification[Class[_]] { def isEqual(x: Class[_], y: Class[_]) = x == y def isSubclass(x: Class[_], y: Class[_]) = y.isAssignableFrom(x) } diff --git a/akka-actor/src/main/scala/akka/io/dns/internal/AsyncDnsManager.scala b/akka-actor/src/main/scala/akka/io/dns/internal/AsyncDnsManager.scala index 026ab274da..2bbea4db71 100644 --- a/akka-actor/src/main/scala/akka/io/dns/internal/AsyncDnsManager.scala +++ b/akka-actor/src/main/scala/akka/io/dns/internal/AsyncDnsManager.scala @@ -20,6 +20,7 @@ import com.github.ghik.silencer.silent import com.typesafe.config.Config import scala.concurrent.duration.Duration +import scala.concurrent.ExecutionContextExecutor /** * INTERNAL API @@ -62,10 +63,10 @@ private[io] final class AsyncDnsManager( ext.Settings.Dispatcher, ext.provider) - implicit val ec = context.dispatcher + implicit val ec: ExecutionContextExecutor = context.dispatcher val settings = new DnsSettings(system, resolverConfig) - implicit val timeout = Timeout(settings.ResolveTimeout) + implicit val timeout: Timeout = Timeout(settings.ResolveTimeout) private val resolver = { val props: Props = FromConfig.props( diff --git a/akka-actor/src/main/scala/akka/io/dns/internal/AsyncDnsResolver.scala b/akka-actor/src/main/scala/akka/io/dns/internal/AsyncDnsResolver.scala index af63617b8d..cbf50dc513 100644 --- a/akka-actor/src/main/scala/akka/io/dns/internal/AsyncDnsResolver.scala +++ b/akka-actor/src/main/scala/akka/io/dns/internal/AsyncDnsResolver.scala @@ -22,6 +22,7 @@ import scala.collection.immutable import scala.concurrent.Future import scala.util.Try import scala.util.control.NonFatal +import scala.concurrent.ExecutionContextExecutor /** * INTERNAL API @@ -36,10 +37,10 @@ private[io] final class AsyncDnsResolver( import AsyncDnsResolver._ - implicit val ec = context.dispatcher + implicit val ec: ExecutionContextExecutor = context.dispatcher // For ask to DNS Client - implicit val timeout = Timeout(settings.ResolveTimeout) + implicit val timeout: Timeout = Timeout(settings.ResolveTimeout) val nameServers = settings.NameServers diff --git a/akka-bench-jmh/src/main/scala/akka/actor/typed/TypedActorBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/actor/typed/TypedActorBenchmark.scala index 809bba8b83..75dc688ad2 100644 --- a/akka-bench-jmh/src/main/scala/akka/actor/typed/TypedActorBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/actor/typed/TypedActorBenchmark.scala @@ -47,7 +47,7 @@ class TypedActorBenchmark { implicit var system: ActorSystem[Start] = _ - implicit val askTimeout = akka.util.Timeout(timeout) + implicit val askTimeout: akka.util.Timeout = akka.util.Timeout(timeout) @Setup(Level.Trial) def setup(): Unit = { diff --git a/akka-bench-jmh/src/main/scala/akka/actor/typed/delivery/ReliableDeliveryBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/actor/typed/delivery/ReliableDeliveryBenchmark.scala index 7bc51c96c4..19d07e35af 100644 --- a/akka-bench-jmh/src/main/scala/akka/actor/typed/delivery/ReliableDeliveryBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/actor/typed/delivery/ReliableDeliveryBenchmark.scala @@ -206,7 +206,7 @@ class ReliableDeliveryBenchmark { implicit var system: ActorSystem[Guardian.Command] = _ - implicit val askTimeout = akka.util.Timeout(timeout) + implicit val askTimeout: akka.util.Timeout = akka.util.Timeout(timeout) @Setup(Level.Trial) def setup(): Unit = { diff --git a/akka-bench-jmh/src/main/scala/akka/dispatch/NodeQueueBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/dispatch/NodeQueueBenchmark.scala index 4ed8064fde..e4d8273932 100644 --- a/akka-bench-jmh/src/main/scala/akka/dispatch/NodeQueueBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/dispatch/NodeQueueBenchmark.scala @@ -39,7 +39,7 @@ mailbox { mailbox-capacity = 1000000 } """).withFallback(ConfigFactory.load()) - implicit val sys = ActorSystem("ANQ", config) + implicit val sys: ActorSystem = ActorSystem("ANQ", config) val ref = sys.actorOf(Props(new Actor { def receive = { case Stop => sender() ! Stop diff --git a/akka-bench-jmh/src/main/scala/akka/remote/artery/SendQueueBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/remote/artery/SendQueueBenchmark.scala index 4e4134d8e7..870cf1eb8e 100644 --- a/akka-bench-jmh/src/main/scala/akka/remote/artery/SendQueueBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/remote/artery/SendQueueBenchmark.scala @@ -31,7 +31,7 @@ class SendQueueBenchmark { val config = ConfigFactory.parseString(""" """) - implicit val system = ActorSystem("SendQueueBenchmark", config) + implicit val system: ActorSystem = ActorSystem("SendQueueBenchmark", config) @Setup def setup(): Unit = { diff --git a/akka-bench-jmh/src/main/scala/akka/stream/AskBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/stream/AskBenchmark.scala index df4227b454..a6d1599a0a 100644 --- a/akka-bench-jmh/src/main/scala/akka/stream/AskBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/stream/AskBenchmark.scala @@ -42,14 +42,14 @@ class AskBenchmark { } """) - implicit val system = ActorSystem("MapAsyncBenchmark", config) + implicit val system: ActorSystem = ActorSystem("MapAsyncBenchmark", config) import system.dispatcher var testSource: Source[java.lang.Integer, NotUsed] = _ var actor: ActorRef = _ - implicit val timeout = Timeout(10.seconds) + implicit val timeout: Timeout = Timeout(10.seconds) @Param(Array("1", "4")) var parallelism = 0 diff --git a/akka-bench-jmh/src/main/scala/akka/stream/EmptySourceBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/stream/EmptySourceBenchmark.scala index 4dd4cf79e4..f866bf496c 100644 --- a/akka-bench-jmh/src/main/scala/akka/stream/EmptySourceBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/stream/EmptySourceBenchmark.scala @@ -17,7 +17,7 @@ import scala.concurrent.duration._ @OutputTimeUnit(TimeUnit.MILLISECONDS) @BenchmarkMode(Array(Mode.Throughput)) class EmptySourceBenchmark { - implicit val system = ActorSystem("EmptySourceBenchmark") + implicit val system: ActorSystem = ActorSystem("EmptySourceBenchmark") @TearDown def shutdown(): Unit = { diff --git a/akka-bench-jmh/src/main/scala/akka/stream/FlatMapMergeBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/stream/FlatMapMergeBenchmark.scala index abb757d0ed..30b94bfe90 100644 --- a/akka-bench-jmh/src/main/scala/akka/stream/FlatMapMergeBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/stream/FlatMapMergeBenchmark.scala @@ -17,7 +17,7 @@ import scala.concurrent.duration._ @OutputTimeUnit(TimeUnit.MILLISECONDS) @BenchmarkMode(Array(Mode.Throughput)) class FlatMapMergeBenchmark { - implicit val system = ActorSystem("FlatMapMergeBenchmark") + implicit val system: ActorSystem = ActorSystem("FlatMapMergeBenchmark") val NumberOfElements = 100000 diff --git a/akka-bench-jmh/src/main/scala/akka/stream/FlowMapBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/stream/FlowMapBenchmark.scala index e624331f61..459877b19e 100644 --- a/akka-bench-jmh/src/main/scala/akka/stream/FlowMapBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/stream/FlowMapBenchmark.scala @@ -48,7 +48,7 @@ class FlowMapBenchmark { } }""".stripMargin).withFallback(ConfigFactory.load()) - implicit val system = ActorSystem("test", config) + implicit val system: ActorSystem = ActorSystem("test", config) @Param(Array("true", "false")) var UseGraphStageIdentity = false diff --git a/akka-bench-jmh/src/main/scala/akka/stream/FusedGraphsBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/stream/FusedGraphsBenchmark.scala index a610645d9a..2d1ec393b3 100644 --- a/akka-bench-jmh/src/main/scala/akka/stream/FusedGraphsBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/stream/FusedGraphsBenchmark.scala @@ -96,7 +96,7 @@ class IdentityStage extends GraphStage[FlowShape[MutableElement, MutableElement] class FusedGraphsBenchmark { import FusedGraphsBenchmark._ - implicit val system = ActorSystem( + implicit val system: ActorSystem = ActorSystem( "test", ConfigFactory.parseString(s""" akka.stream.materializer.sync-processing-limit = ${Int.MaxValue} diff --git a/akka-bench-jmh/src/main/scala/akka/stream/InvokeWithFeedbackBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/stream/InvokeWithFeedbackBenchmark.scala index 1cccae1476..06fa874c80 100644 --- a/akka-bench-jmh/src/main/scala/akka/stream/InvokeWithFeedbackBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/stream/InvokeWithFeedbackBenchmark.scala @@ -17,7 +17,7 @@ import scala.concurrent.duration._ @OutputTimeUnit(TimeUnit.SECONDS) @BenchmarkMode(Array(Mode.Throughput)) class InvokeWithFeedbackBenchmark { - implicit val system = ActorSystem("InvokeWithFeedbackBenchmark") + implicit val system: ActorSystem = ActorSystem("InvokeWithFeedbackBenchmark") var sourceQueue: SourceQueueWithComplete[Int] = _ var sinkQueue: SinkQueueWithCancel[Int] = _ diff --git a/akka-bench-jmh/src/main/scala/akka/stream/MapAsyncBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/stream/MapAsyncBenchmark.scala index a77c8d25e5..3d294e9fc9 100644 --- a/akka-bench-jmh/src/main/scala/akka/stream/MapAsyncBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/stream/MapAsyncBenchmark.scala @@ -39,7 +39,7 @@ class MapAsyncBenchmark { } """) - implicit val system = ActorSystem("MapAsyncBenchmark", config) + implicit val system: ActorSystem = ActorSystem("MapAsyncBenchmark", config) import system.dispatcher var testSource: Source[java.lang.Integer, NotUsed] = _ diff --git a/akka-bench-jmh/src/main/scala/akka/stream/MaterializationBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/stream/MaterializationBenchmark.scala index bdbd7bcadc..6d8445d105 100644 --- a/akka-bench-jmh/src/main/scala/akka/stream/MaterializationBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/stream/MaterializationBenchmark.scala @@ -96,7 +96,7 @@ class MaterializationBenchmark { import MaterializationBenchmark._ - implicit val system = ActorSystem("MaterializationBenchmark") + implicit val system: ActorSystem = ActorSystem("MaterializationBenchmark") var flowWithMap: RunnableGraph[NotUsed] = _ var graphWithJunctionsGradual: RunnableGraph[NotUsed] = _ diff --git a/akka-bench-jmh/src/main/scala/akka/stream/PartitionHubBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/stream/PartitionHubBenchmark.scala index 0086667d7e..d01c35de78 100644 --- a/akka-bench-jmh/src/main/scala/akka/stream/PartitionHubBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/stream/PartitionHubBenchmark.scala @@ -40,7 +40,7 @@ class PartitionHubBenchmark { } """) - implicit val system = ActorSystem("PartitionHubBenchmark", config) + implicit val system: ActorSystem = ActorSystem("PartitionHubBenchmark", config) @Param(Array("2", "5", "10", "20", "30")) var NumberOfStreams = 0 diff --git a/akka-bench-jmh/src/main/scala/akka/stream/SourceRefBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/stream/SourceRefBenchmark.scala index 043b9bffcb..a191c8bb56 100644 --- a/akka-bench-jmh/src/main/scala/akka/stream/SourceRefBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/stream/SourceRefBenchmark.scala @@ -33,7 +33,7 @@ class SourceRefBenchmark { loglevel = "WARNING" }""".stripMargin).withFallback(ConfigFactory.load()) - implicit val system = ActorSystem("test", config) + implicit val system: ActorSystem = ActorSystem("test", config) final val successMarker = Success(1) final val successFailure = Success(new Exception) diff --git a/akka-bench-jmh/src/main/scala/akka/stream/impl/OutputStreamSourceStageBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/stream/impl/OutputStreamSourceStageBenchmark.scala index 7f7bf45bdc..c6af31b03a 100644 --- a/akka-bench-jmh/src/main/scala/akka/stream/impl/OutputStreamSourceStageBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/stream/impl/OutputStreamSourceStageBenchmark.scala @@ -24,7 +24,7 @@ object OutputStreamSourceStageBenchmark { @BenchmarkMode(Array(Mode.Throughput)) class OutputStreamSourceStageBenchmark { import OutputStreamSourceStageBenchmark.WritesPerBench - implicit val system = ActorSystem("OutputStreamSourceStageBenchmark") + implicit val system: ActorSystem = ActorSystem("OutputStreamSourceStageBenchmark") private val bytes: Array[Byte] = Array.emptyByteArray diff --git a/akka-bench-jmh/src/main/scala/akka/stream/io/FileSourcesBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/stream/io/FileSourcesBenchmark.scala index 6355866a9b..5c8323d6d5 100644 --- a/akka-bench-jmh/src/main/scala/akka/stream/io/FileSourcesBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/stream/io/FileSourcesBenchmark.scala @@ -31,7 +31,7 @@ import scala.concurrent.Promise @BenchmarkMode(Array(Mode.AverageTime)) class FileSourcesBenchmark { - implicit val system = ActorSystem("file-sources-benchmark") + implicit val system: ActorSystem = ActorSystem("file-sources-benchmark") val file: Path = { val line = ByteString("x" * 2048 + "\n") diff --git a/akka-bench-jmh/src/main/scala/akka/stream/io/FileSourcesScaleBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/stream/io/FileSourcesScaleBenchmark.scala index 4959f22081..dcdd4f75df 100644 --- a/akka-bench-jmh/src/main/scala/akka/stream/io/FileSourcesScaleBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/stream/io/FileSourcesScaleBenchmark.scala @@ -34,7 +34,7 @@ class FileSourcesScaleBenchmark { * FileSourcesScaleBenchmark.flatMapMerge 2048 avgt 10 1.587 ± 0.118 s/op * FileSourcesScaleBenchmark.mapAsync 2048 avgt 10 0.899 ± 0.103 s/op */ - implicit val system = ActorSystem("file-sources-benchmark") + implicit val system: ActorSystem = ActorSystem("file-sources-benchmark") val FILES_NUMBER = 40 val files: Seq[Path] = { diff --git a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala index 7be3ba6e63..83cb410570 100644 --- a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala +++ b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala @@ -780,8 +780,8 @@ private[akka] class DDataShard( private val writeMajority = WriteMajority(settings.tuningParameters.updatingStateTimeout, majorityMinCap) private val maxUpdateAttempts = 3 - implicit private val node = Cluster(context.system) - implicit private val selfUniqueAddress = SelfUniqueAddress(node.selfUniqueAddress) + implicit private val node: Cluster = Cluster(context.system) + implicit private val selfUniqueAddress: SelfUniqueAddress = SelfUniqueAddress(node.selfUniqueAddress) // The default maximum-frame-size is 256 KiB with Artery. // When using entity identifiers with 36 character strings (e.g. UUID.randomUUID). diff --git a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala index 8f9fc8b13f..24c991ed97 100644 --- a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala +++ b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala @@ -1100,8 +1100,8 @@ class DDataShardCoordinator( private val readMajority = ReadMajority(settings.tuningParameters.waitingForStateTimeout, majorityMinCap) private val writeMajority = WriteMajority(settings.tuningParameters.updatingStateTimeout, majorityMinCap) - implicit val node = Cluster(context.system) - private implicit val selfUniqueAddress = SelfUniqueAddress(node.selfUniqueAddress) + implicit val node: Cluster = Cluster(context.system) + private implicit val selfUniqueAddress: SelfUniqueAddress = SelfUniqueAddress(node.selfUniqueAddress) val CoordinatorStateKey = LWWRegisterKey[State](s"${typeName}CoordinatorState") val initEmptyState = State.empty.withRememberEntities(settings.rememberEntities) diff --git a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/external/internal/ExternalShardAllocationClientImpl.scala b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/external/internal/ExternalShardAllocationClientImpl.scala index 08c6bbf569..f58d056b5e 100644 --- a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/external/internal/ExternalShardAllocationClientImpl.scala +++ b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/external/internal/ExternalShardAllocationClientImpl.scala @@ -37,6 +37,7 @@ import akka.pattern.ask import scala.concurrent.Future import scala.compat.java8.FutureConverters._ import akka.util.JavaDurationConverters._ +import akka.dispatch.MessageDispatcher /** * INTERNAL API @@ -55,8 +56,8 @@ final private[external] class ExternalShardAllocationClientImpl(system: ActorSys system.settings.config .getDuration("akka.cluster.sharding.external-shard-allocation-strategy.client-timeout") .asScala - private implicit val askTimeout = Timeout(timeout * 2) - private implicit val ec = system.dispatchers.internalDispatcher + private implicit val askTimeout: Timeout = Timeout(timeout * 2) + private implicit val ec: MessageDispatcher = system.dispatchers.internalDispatcher private val Key = ExternalShardAllocationStrategy.ddataKey(typeName) diff --git a/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ClusterShardingCustomShardAllocationSpec.scala b/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ClusterShardingCustomShardAllocationSpec.scala index 851b7aa460..12693ffb96 100644 --- a/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ClusterShardingCustomShardAllocationSpec.scala +++ b/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ClusterShardingCustomShardAllocationSpec.scala @@ -43,7 +43,7 @@ object ClusterShardingCustomShardAllocationSpec { } case class TestAllocationStrategy(ref: ActorRef) extends ShardAllocationStrategy { - implicit val timeout = Timeout(3.seconds) + implicit val timeout: Timeout = Timeout(3.seconds) override def allocateShard( requester: ActorRef, shardId: ShardRegion.ShardId, diff --git a/akka-cluster-tools/src/multi-jvm/scala/akka/cluster/TestLeaseActor.scala b/akka-cluster-tools/src/multi-jvm/scala/akka/cluster/TestLeaseActor.scala index 54d03ba74c..e0eee38139 100644 --- a/akka-cluster-tools/src/multi-jvm/scala/akka/cluster/TestLeaseActor.scala +++ b/akka-cluster-tools/src/multi-jvm/scala/akka/cluster/TestLeaseActor.scala @@ -102,7 +102,7 @@ class TestLeaseActorClient(settings: LeaseSettings, system: ExtendedActorSystem) log.info("lease created {}", settings) leaseActor ! Create(settings.leaseName, settings.ownerName) - private implicit val timeout = Timeout(100.seconds) + private implicit val timeout: Timeout = Timeout(100.seconds) override def acquire(): Future[Boolean] = { (leaseActor ? Acquire(settings.ownerName)).mapTo[Boolean] diff --git a/akka-cluster-typed/src/main/scala/akka/cluster/typed/internal/receptionist/ClusterReceptionist.scala b/akka-cluster-typed/src/main/scala/akka/cluster/typed/internal/receptionist/ClusterReceptionist.scala index 5a6054ffe8..5b67dacfeb 100644 --- a/akka-cluster-typed/src/main/scala/akka/cluster/typed/internal/receptionist/ClusterReceptionist.scala +++ b/akka-cluster-typed/src/main/scala/akka/cluster/typed/internal/receptionist/ClusterReceptionist.scala @@ -184,7 +184,7 @@ private[typed] object ClusterReceptionist extends ReceptionistBehaviorProvider { val cluster = Cluster(classicSystem) // don't use DistributedData.selfUniqueAddress here, because that will initialize extension, which // isn't used otherwise by the ClusterReceptionist - implicit val selfNodeAddress = SelfUniqueAddress(cluster.selfUniqueAddress) + implicit val selfNodeAddress: SelfUniqueAddress = SelfUniqueAddress(cluster.selfUniqueAddress) val replicator = ctx.actorOf(Replicator.props(settings.replicatorSettings), "replicator") diff --git a/akka-cluster-typed/src/test/scala/akka/cluster/typed/ClusterSingletonApiSpec.scala b/akka-cluster-typed/src/test/scala/akka/cluster/typed/ClusterSingletonApiSpec.scala index c8feaa0160..774f2c2f4a 100644 --- a/akka-cluster-typed/src/test/scala/akka/cluster/typed/ClusterSingletonApiSpec.scala +++ b/akka-cluster-typed/src/test/scala/akka/cluster/typed/ClusterSingletonApiSpec.scala @@ -54,7 +54,7 @@ class ClusterSingletonApiSpec with LogCapturing { import ClusterSingletonApiSpec._ - implicit val testSettings = TestKitSettings(system) + implicit val testSettings: TestKitSettings = TestKitSettings(system) val clusterNode1 = Cluster(system) val classicSystem1 = system.toClassic diff --git a/akka-cluster-typed/src/test/scala/akka/cluster/typed/ClusterSingletonPoisonPillSpec.scala b/akka-cluster-typed/src/test/scala/akka/cluster/typed/ClusterSingletonPoisonPillSpec.scala index 3cf7185080..a2bb04cee9 100644 --- a/akka-cluster-typed/src/test/scala/akka/cluster/typed/ClusterSingletonPoisonPillSpec.scala +++ b/akka-cluster-typed/src/test/scala/akka/cluster/typed/ClusterSingletonPoisonPillSpec.scala @@ -31,7 +31,7 @@ class ClusterSingletonPoisonPillSpec with AnyWordSpecLike with LogCapturing { - implicit val testSettings = TestKitSettings(system) + implicit val testSettings: TestKitSettings = TestKitSettings(system) val clusterNode1 = Cluster(system) clusterNode1.manager ! Join(clusterNode1.selfMember.address) val classicSystem1 = system.toClassic diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/StreamRefSpec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/StreamRefSpec.scala index ff35f1c2f7..479f6c51c4 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/StreamRefSpec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/StreamRefSpec.scala @@ -56,7 +56,7 @@ object StreamRefSpec extends MultiNodeConfig { class DataSource(streamLifecycleProbe: ActorRef) extends Actor with ActorLogging { import context.dispatcher - implicit val mat = Materializer(context) + implicit val mat: Materializer = Materializer(context) def receive = { case RequestLogs(streamId) => @@ -102,7 +102,7 @@ object StreamRefSpec extends MultiNodeConfig { class DataReceiver(streamLifecycleProbe: ActorRef) extends Actor with ActorLogging { import context.dispatcher - implicit val mat = Materializer(context) + implicit val mat: Materializer = Materializer(context) def receive = { case PrepareUpload(nodeId) => diff --git a/akka-discovery/src/main/scala/akka/discovery/aggregate/AggregateServiceDiscovery.scala b/akka-discovery/src/main/scala/akka/discovery/aggregate/AggregateServiceDiscovery.scala index 94fcd8cf92..3866832f6f 100644 --- a/akka-discovery/src/main/scala/akka/discovery/aggregate/AggregateServiceDiscovery.scala +++ b/akka-discovery/src/main/scala/akka/discovery/aggregate/AggregateServiceDiscovery.scala @@ -17,6 +17,7 @@ import akka.util.ccompat.JavaConverters._ import scala.concurrent.Future import scala.concurrent.duration.FiniteDuration import scala.util.control.NonFatal +import akka.dispatch.MessageDispatcher /** * INTERNAL API @@ -55,7 +56,7 @@ private[akka] final class AggregateServiceDiscovery(system: ExtendedActorSystem) val serviceDiscovery = Discovery(system) settings.discoveryMethods.map(mech => (mech, serviceDiscovery.loadServiceDiscovery(mech))) } - private implicit val ec = system.dispatchers.internalDispatcher + private implicit val ec: MessageDispatcher = system.dispatchers.internalDispatcher /** * Each discovery method is given the resolveTimeout rather than reducing it each time between methods. diff --git a/akka-discovery/src/main/scala/akka/discovery/dns/DnsServiceDiscovery.scala b/akka-discovery/src/main/scala/akka/discovery/dns/DnsServiceDiscovery.scala index 2ff2d20406..a15a66a31e 100644 --- a/akka-discovery/src/main/scala/akka/discovery/dns/DnsServiceDiscovery.scala +++ b/akka-discovery/src/main/scala/akka/discovery/dns/DnsServiceDiscovery.scala @@ -30,6 +30,7 @@ import akka.io.dns.internal.AsyncDnsManager import akka.pattern.AskTimeoutException import akka.util.OptionVal import akka.util.Timeout +import akka.dispatch.MessageDispatcher /** * INTERNAL API @@ -91,7 +92,7 @@ private[akka] class DnsServiceDiscovery(system: ExtendedActorSystem) extends Ser // (eventually visible) private var asyncDnsCache: OptionVal[SimpleDnsCache] = OptionVal.None - private implicit val ec = system.dispatchers.internalDispatcher + private implicit val ec: MessageDispatcher = system.dispatchers.internalDispatcher dns.ask(AsyncDnsManager.GetCache)(Timeout(30.seconds)).onComplete { case Success(cache: SimpleDnsCache) => diff --git a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/DurableDataSpec.scala b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/DurableDataSpec.scala index 13cdc917d3..9ce697e8cc 100644 --- a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/DurableDataSpec.scala +++ b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/DurableDataSpec.scala @@ -84,7 +84,7 @@ abstract class DurableDataSpec(multiNodeConfig: DurableDataSpecConfig) override def initialParticipants = roles.size val cluster = Cluster(system) - implicit val selfUniqueAddress = DistributedData(system).selfUniqueAddress + implicit val selfUniqueAddress: SelfUniqueAddress = DistributedData(system).selfUniqueAddress val timeout = 14.seconds.dilated // initialization of lmdb can be very slow in CI environment val writeTwo = WriteTo(2, timeout) val readTwo = ReadFrom(2, timeout) diff --git a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/DurablePruningSpec.scala b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/DurablePruningSpec.scala index dbff51aeae..f21ae1b582 100644 --- a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/DurablePruningSpec.scala +++ b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/DurablePruningSpec.scala @@ -46,7 +46,7 @@ class DurablePruningSpec extends MultiNodeSpec(DurablePruningSpec) with STMultiN override def initialParticipants = roles.size val cluster = Cluster(system) - implicit val selfUniqueAddress = DistributedData(system).selfUniqueAddress + implicit val selfUniqueAddress: SelfUniqueAddress = DistributedData(system).selfUniqueAddress val maxPruningDissemination = 3.seconds def startReplicator(sys: ActorSystem): ActorRef = diff --git a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/JepsenInspiredInsertSpec.scala b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/JepsenInspiredInsertSpec.scala index a4db728c6b..5ab555eeeb 100644 --- a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/JepsenInspiredInsertSpec.scala +++ b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/JepsenInspiredInsertSpec.scala @@ -53,7 +53,7 @@ class JepsenInspiredInsertSpec override def initialParticipants = roles.size val cluster = Cluster(system) - implicit val selfUniqueAddress = DistributedData(system).selfUniqueAddress + implicit val selfUniqueAddress: SelfUniqueAddress = DistributedData(system).selfUniqueAddress val replicator = DistributedData(system).replicator val nodes = roles.drop(1) // controller not part of active nodes val nodeCount = nodes.size diff --git a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/PerformanceSpec.scala b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/PerformanceSpec.scala index 47036ba068..140b4087a1 100644 --- a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/PerformanceSpec.scala +++ b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/PerformanceSpec.scala @@ -69,7 +69,7 @@ class PerformanceSpec extends MultiNodeSpec(PerformanceSpec) with STMultiNodeSpe override def initialParticipants = roles.size val cluster = Cluster(system) - implicit val selfUniqueAddress = DistributedData(system).selfUniqueAddress + implicit val selfUniqueAddress: SelfUniqueAddress = DistributedData(system).selfUniqueAddress val replicator = DistributedData(system).replicator val timeout = 3.seconds.dilated val factor = 1 // use 3 here for serious tuning diff --git a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorChaosSpec.scala b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorChaosSpec.scala index 3263eb751b..110d86057e 100644 --- a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorChaosSpec.scala +++ b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorChaosSpec.scala @@ -44,7 +44,7 @@ class ReplicatorChaosSpec extends MultiNodeSpec(ReplicatorChaosSpec) with STMult override def initialParticipants = roles.size val cluster = Cluster(system) - implicit val selfUniqueAddress = DistributedData(system).selfUniqueAddress + implicit val selfUniqueAddress: SelfUniqueAddress = DistributedData(system).selfUniqueAddress val replicator = system.actorOf( Replicator.props(ReplicatorSettings(system).withRole("backend").withGossipInterval(1.second)), "replicator") diff --git a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorDeltaSpec.scala b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorDeltaSpec.scala index 918c0c009b..b78501caaf 100644 --- a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorDeltaSpec.scala +++ b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorDeltaSpec.scala @@ -146,7 +146,7 @@ class ReplicatorDeltaSpec extends MultiNodeSpec(ReplicatorDeltaSpec) with STMult override def initialParticipants = roles.size val cluster = Cluster(system) - implicit val selfUniqueAddress = DistributedData(system).selfUniqueAddress + implicit val selfUniqueAddress: SelfUniqueAddress = DistributedData(system).selfUniqueAddress val fullStateReplicator = system.actorOf( Replicator.props(ReplicatorSettings(system).withGossipInterval(1.second).withDeltaCrdtEnabled(false)), "fullStateReplicator") diff --git a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorMapDeltaSpec.scala b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorMapDeltaSpec.scala index d5da64e92b..8bffebdb23 100644 --- a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorMapDeltaSpec.scala +++ b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorMapDeltaSpec.scala @@ -186,7 +186,7 @@ class ReplicatorMapDeltaSpec extends MultiNodeSpec(ReplicatorMapDeltaSpec) with override def initialParticipants = roles.size val cluster = Cluster(system) - implicit val selfUniqueAddress = DistributedData(system).selfUniqueAddress + implicit val selfUniqueAddress: SelfUniqueAddress = DistributedData(system).selfUniqueAddress val fullStateReplicator = system.actorOf( Replicator.props(ReplicatorSettings(system).withGossipInterval(1.second).withDeltaCrdtEnabled(false)), "fullStateReplicator") diff --git a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorORSetDeltaSpec.scala b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorORSetDeltaSpec.scala index a531d123a0..525e3903a7 100644 --- a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorORSetDeltaSpec.scala +++ b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorORSetDeltaSpec.scala @@ -42,7 +42,7 @@ class ReplicatorORSetDeltaSpec override def initialParticipants = roles.size val cluster = Cluster(system) - implicit val selfUniqueAddress = DistributedData(system).selfUniqueAddress + implicit val selfUniqueAddress: SelfUniqueAddress = DistributedData(system).selfUniqueAddress val replicator = system.actorOf(Replicator.props(ReplicatorSettings(system).withGossipInterval(1.second)), "replicator") val timeout = 3.seconds.dilated diff --git a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorPruningSpec.scala b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorPruningSpec.scala index d40afe9b39..7d6e95fd43 100644 --- a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorPruningSpec.scala +++ b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorPruningSpec.scala @@ -42,7 +42,7 @@ class ReplicatorPruningSpec extends MultiNodeSpec(ReplicatorPruningSpec) with ST override def initialParticipants = roles.size val cluster = Cluster(system) - implicit val selfUniqueAddress = DistributedData(system).selfUniqueAddress + implicit val selfUniqueAddress: SelfUniqueAddress = DistributedData(system).selfUniqueAddress val maxPruningDissemination = 3.seconds val replicator = system.actorOf( Replicator.props( diff --git a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorSpec.scala b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorSpec.scala index ca4cde72a8..ba81b0a3d9 100644 --- a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorSpec.scala +++ b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorSpec.scala @@ -44,7 +44,7 @@ class ReplicatorSpec extends MultiNodeSpec(ReplicatorSpec) with STMultiNodeSpec override def initialParticipants = roles.size val cluster = Cluster(system) - implicit val selfUniqueAddress = DistributedData(system).selfUniqueAddress + implicit val selfUniqueAddress: SelfUniqueAddress = DistributedData(system).selfUniqueAddress val replicator = system.actorOf( Replicator.props(ReplicatorSettings(system).withGossipInterval(1.second).withMaxDeltaElements(10)), "replicator") diff --git a/akka-distributed-data/src/test/scala/akka/cluster/ddata/LocalConcurrencySpec.scala b/akka-distributed-data/src/test/scala/akka/cluster/ddata/LocalConcurrencySpec.scala index 3f069e75e4..a249c0e5c5 100644 --- a/akka-distributed-data/src/test/scala/akka/cluster/ddata/LocalConcurrencySpec.scala +++ b/akka-distributed-data/src/test/scala/akka/cluster/ddata/LocalConcurrencySpec.scala @@ -25,7 +25,7 @@ object LocalConcurrencySpec { class Updater extends Actor with Stash { - implicit val selfUniqueAddress = DistributedData(context.system).selfUniqueAddress + implicit val selfUniqueAddress: SelfUniqueAddress = DistributedData(context.system).selfUniqueAddress val replicator = DistributedData(context.system).replicator diff --git a/akka-distributed-data/src/test/scala/akka/cluster/ddata/LotsOfDataBot.scala b/akka-distributed-data/src/test/scala/akka/cluster/ddata/LotsOfDataBot.scala index 56dc42a36b..570e00168d 100644 --- a/akka-distributed-data/src/test/scala/akka/cluster/ddata/LotsOfDataBot.scala +++ b/akka-distributed-data/src/test/scala/akka/cluster/ddata/LotsOfDataBot.scala @@ -69,7 +69,7 @@ class LotsOfDataBot extends Actor with ActorLogging { import LotsOfDataBot._ import Replicator._ - implicit val selfUniqueAddress = DistributedData(context.system).selfUniqueAddress + implicit val selfUniqueAddress: SelfUniqueAddress = DistributedData(context.system).selfUniqueAddress val replicator = DistributedData(context.system).replicator import context.dispatcher diff --git a/akka-multi-node-testkit/src/main/scala/akka/remote/testconductor/Conductor.scala b/akka-multi-node-testkit/src/main/scala/akka/remote/testconductor/Conductor.scala index 1f2c62af1f..ab5b8eeb9e 100644 --- a/akka-multi-node-testkit/src/main/scala/akka/remote/testconductor/Conductor.scala +++ b/akka-multi-node-testkit/src/main/scala/akka/remote/testconductor/Conductor.scala @@ -277,7 +277,7 @@ trait Conductor { this: TestConductorExt => private[akka] class ConductorHandler(_createTimeout: Timeout, controller: ActorRef, log: LoggingAdapter) extends SimpleChannelUpstreamHandler { - implicit val createTimeout = _createTimeout + implicit val createTimeout: Timeout = _createTimeout val clients = new ConcurrentHashMap[Channel, ActorRef]() override def channelConnected(ctx: ChannelHandlerContext, event: ChannelStateEvent) = { diff --git a/akka-multi-node-testkit/src/main/scala/akka/remote/testconductor/Extension.scala b/akka-multi-node-testkit/src/main/scala/akka/remote/testconductor/Extension.scala index fa890120b3..b2ccb8b8a3 100644 --- a/akka-multi-node-testkit/src/main/scala/akka/remote/testconductor/Extension.scala +++ b/akka-multi-node-testkit/src/main/scala/akka/remote/testconductor/Extension.scala @@ -62,8 +62,8 @@ class TestConductorExt(val system: ExtendedActorSystem) extends Extension with C val ClientReconnects = config.getInt("client-reconnects") val ReconnectBackoff = config.getMillisDuration("reconnect-backoff") - implicit val BarrierTimeout = Timeout(config.getMillisDuration("barrier-timeout")) - implicit val QueryTimeout = Timeout(config.getMillisDuration("query-timeout")) + implicit val BarrierTimeout: Timeout = Timeout(config.getMillisDuration("barrier-timeout")) + implicit val QueryTimeout: Timeout = Timeout(config.getMillisDuration("query-timeout")) val PacketSplitThreshold = config.getMillisDuration("packet-split-threshold") private def computeWPS(config: Config): Int = diff --git a/akka-persistence-tck/src/main/scala/akka/persistence/snapshot/SnapshotStoreSpec.scala b/akka-persistence-tck/src/main/scala/akka/persistence/snapshot/SnapshotStoreSpec.scala index 667cf50d68..3c506d4c2b 100644 --- a/akka-persistence-tck/src/main/scala/akka/persistence/snapshot/SnapshotStoreSpec.scala +++ b/akka-persistence-tck/src/main/scala/akka/persistence/snapshot/SnapshotStoreSpec.scala @@ -44,7 +44,8 @@ abstract class SnapshotStoreSpec(config: Config) with MayVerb with OptionalTests with SnapshotStoreCapabilityFlags { - implicit lazy val system = ActorSystem("SnapshotStoreSpec", config.withFallback(SnapshotStoreSpec.config)) + implicit lazy val system: ActorSystem = + ActorSystem("SnapshotStoreSpec", config.withFallback(SnapshotStoreSpec.config)) private var senderProbe: TestProbe = _ private var metadata: Seq[SnapshotMetadata] = Nil diff --git a/akka-persistence-typed/src/test/scala/akka/persistence/typed/ClusterSingletonPersistenceSpec.scala b/akka-persistence-typed/src/test/scala/akka/persistence/typed/ClusterSingletonPersistenceSpec.scala index 3ad3ec629f..4ffe53da65 100644 --- a/akka-persistence-typed/src/test/scala/akka/persistence/typed/ClusterSingletonPersistenceSpec.scala +++ b/akka-persistence-typed/src/test/scala/akka/persistence/typed/ClusterSingletonPersistenceSpec.scala @@ -15,6 +15,8 @@ import akka.persistence.typed.scaladsl.Effect import akka.persistence.typed.scaladsl.EventSourcedBehavior import com.typesafe.config.ConfigFactory import org.scalatest.wordspec.AnyWordSpecLike +import akka.actor +import akka.actor.typed.ActorSystem object ClusterSingletonPersistenceSpec { val config = ConfigFactory.parseString(""" @@ -57,9 +59,9 @@ class ClusterSingletonPersistenceSpec import ClusterSingletonPersistenceSpec._ import akka.actor.typed.scaladsl.adapter._ - implicit val s = system + implicit val s: ActorSystem[Nothing] = system - implicit val classicSystem = system.toClassic + implicit val classicSystem: actor.ActorSystem = system.toClassic private val classicCluster = akka.cluster.Cluster(classicSystem) "A typed cluster singleton with persistent actor" must { diff --git a/akka-persistence-typed/src/test/scala/akka/persistence/typed/internal/RecoveryPermitterSpec.scala b/akka-persistence-typed/src/test/scala/akka/persistence/typed/internal/RecoveryPermitterSpec.scala index afa7624024..7dbd615e2a 100644 --- a/akka-persistence-typed/src/test/scala/akka/persistence/typed/internal/RecoveryPermitterSpec.scala +++ b/akka-persistence-typed/src/test/scala/akka/persistence/typed/internal/RecoveryPermitterSpec.scala @@ -22,6 +22,7 @@ import akka.actor.testkit.typed.scaladsl.LogCapturing import akka.persistence.typed.PersistenceId import akka.persistence.typed.RecoveryCompleted import org.scalatest.wordspec.AnyWordSpecLike +import akka.actor.ActorSystem object RecoveryPermitterSpec { @@ -76,7 +77,7 @@ class RecoveryPermitterSpec extends ScalaTestWithActorTestKit(s""" import RecoveryPermitterSpec._ - implicit val classicSystem = system.toClassic + implicit val classicSystem: ActorSystem = system.toClassic private val permitter = Persistence(classicSystem).recoveryPermitter diff --git a/akka-persistence-typed/src/test/scala/akka/persistence/typed/scaladsl/NullEmptyStateSpec.scala b/akka-persistence-typed/src/test/scala/akka/persistence/typed/scaladsl/NullEmptyStateSpec.scala index b98de12bbc..e25146f6b1 100644 --- a/akka-persistence-typed/src/test/scala/akka/persistence/typed/scaladsl/NullEmptyStateSpec.scala +++ b/akka-persistence-typed/src/test/scala/akka/persistence/typed/scaladsl/NullEmptyStateSpec.scala @@ -26,7 +26,7 @@ class NullEmptyStateSpec with AnyWordSpecLike with LogCapturing { - implicit val testSettings = TestKitSettings(system) + implicit val testSettings: TestKitSettings = TestKitSettings(system) def primitiveState(persistenceId: PersistenceId, probe: ActorRef[String]): Behavior[String] = EventSourcedBehavior[String, String, String]( diff --git a/akka-persistence/src/main/scala/akka/persistence/fsm/PersistentFSM.scala b/akka-persistence/src/main/scala/akka/persistence/fsm/PersistentFSM.scala index f520059791..fca43099e6 100644 --- a/akka-persistence/src/main/scala/akka/persistence/fsm/PersistentFSM.scala +++ b/akka-persistence/src/main/scala/akka/persistence/fsm/PersistentFSM.scala @@ -17,6 +17,7 @@ import scala.annotation.varargs import scala.collection.immutable import scala.concurrent.duration._ import scala.reflect.ClassTag +import scala.concurrent.ExecutionContextExecutor /** * SnapshotAfter Extension Id and factory for creating SnapshotAfter extension @@ -331,7 +332,7 @@ object PersistentFSM { extends NoSerializationVerificationNeeded { private var ref: Option[Cancellable] = _ private val scheduler = context.system.scheduler - private implicit val executionContext = context.dispatcher + private implicit val executionContext: ExecutionContextExecutor = context.dispatcher def schedule(actor: ActorRef, timeout: FiniteDuration): Unit = { val timerMsg = msg match { diff --git a/akka-remote/src/main/scala/akka/remote/FailureDetector.scala b/akka-remote/src/main/scala/akka/remote/FailureDetector.scala index a30b15ff20..bd157af2c9 100644 --- a/akka-remote/src/main/scala/akka/remote/FailureDetector.scala +++ b/akka-remote/src/main/scala/akka/remote/FailureDetector.scala @@ -40,7 +40,7 @@ object FailureDetector { // Abstract class to be able to extend it from Java abstract class Clock extends (() => Long) - implicit val defaultClock = new Clock { + implicit val defaultClock: Clock = new Clock { def apply() = NANOSECONDS.toMillis(System.nanoTime) } } diff --git a/akka-remote/src/main/scala/akka/remote/Remoting.scala b/akka-remote/src/main/scala/akka/remote/Remoting.scala index 1169e15a01..a78292fd8c 100644 --- a/akka-remote/src/main/scala/akka/remote/Remoting.scala +++ b/akka-remote/src/main/scala/akka/remote/Remoting.scala @@ -34,6 +34,7 @@ import akka.actor.ActorInitializationException import akka.annotation.InternalStableApi import akka.util.ccompat._ import com.github.ghik.silencer.silent +import akka.dispatch.MessageDispatcher /** * INTERNAL API @@ -149,7 +150,7 @@ private[remote] class Remoting(_system: ExtendedActorSystem, _provider: RemoteAc import provider.remoteSettings._ - private implicit val ec = system.dispatchers.lookup(Dispatcher) + private implicit val ec: MessageDispatcher = system.dispatchers.lookup(Dispatcher) val transportSupervisor = system.systemActorOf(configureDispatcher(Props[TransportSupervisor]), "transports") diff --git a/akka-remote/src/main/scala/akka/remote/transport/AbstractTransportAdapter.scala b/akka-remote/src/main/scala/akka/remote/transport/AbstractTransportAdapter.scala index 9ce2c6dd76..0e84dc03b7 100644 --- a/akka-remote/src/main/scala/akka/remote/transport/AbstractTransportAdapter.scala +++ b/akka-remote/src/main/scala/akka/remote/transport/AbstractTransportAdapter.scala @@ -160,7 +160,7 @@ object ActorTransportAdapter { extends TransportOperation with DeadLetterSuppression - implicit val AskTimeout = Timeout(5.seconds) + implicit val AskTimeout: Timeout = Timeout(5.seconds) } @deprecated("Classic remoting is deprecated, use Artery", "2.6.0") diff --git a/akka-remote/src/test/scala/akka/remote/artery/compress/HandshakeShouldDropCompressionTableSpec.scala b/akka-remote/src/test/scala/akka/remote/artery/compress/HandshakeShouldDropCompressionTableSpec.scala index 764c9d2587..975103d1d3 100644 --- a/akka-remote/src/test/scala/akka/remote/artery/compress/HandshakeShouldDropCompressionTableSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/artery/compress/HandshakeShouldDropCompressionTableSpec.scala @@ -39,7 +39,7 @@ class HandshakeShouldDropCompressionTableSpec with ImplicitSender with BeforeAndAfter { - implicit val t = Timeout(3.seconds) + implicit val t: Timeout = Timeout(3.seconds) var systemB: ActorSystem = null val portB = freePort() diff --git a/akka-stream-tests/src/test/scala/akka/stream/ActorMaterializerSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/ActorMaterializerSpec.scala index 56ac524626..37fe7a67c8 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/ActorMaterializerSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/ActorMaterializerSpec.scala @@ -34,7 +34,7 @@ object IndirectMaterializerCreation extends ExtensionId[IndirectMaterializerCrea @silent class IndirectMaterializerCreation(ex: ExtendedActorSystem) extends Extension { // extension instantiation blocked on materializer (which has Await.result inside) - implicit val mat = ActorMaterializer()(ex) + implicit val mat: ActorMaterializer = ActorMaterializer()(ex) def futureThing(n: Int): Future[Int] = { Source.single(n).runWith(Sink.head) @@ -160,7 +160,7 @@ object ActorMaterializerSpec { class ActorWithMaterializer(p: TestProbe) extends Actor { private val settings: ActorMaterializerSettings = ActorMaterializerSettings(context.system).withDispatcher("akka.test.stream-dispatcher") - implicit val mat = ActorMaterializer(settings)(context) + implicit val mat: ActorMaterializer = ActorMaterializer(settings)(context) Source .repeat("hello") diff --git a/akka-stream-tests/src/test/scala/akka/stream/io/FileSinkSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/io/FileSinkSpec.scala index 1fb034e72a..528d2f274b 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/io/FileSinkSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/io/FileSinkSpec.scala @@ -29,7 +29,7 @@ import scala.util.Success class FileSinkSpec extends StreamSpec(UnboundedMailboxConfig) with ScalaFutures { val settings = ActorMaterializerSettings(system).withDispatcher("akka.actor.default-dispatcher") - implicit val materializer = ActorMaterializer(settings) + implicit val materializer: ActorMaterializer = ActorMaterializer(settings) val fs = Jimfs.newFileSystem("FileSinkSpec", Configuration.unix()) val TestLines = { diff --git a/akka-stream-tests/src/test/scala/akka/stream/io/FileSourceSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/io/FileSourceSpec.scala index 5b3006db58..238fda129b 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/io/FileSourceSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/io/FileSourceSpec.scala @@ -35,7 +35,7 @@ object FileSourceSpec { class FileSourceSpec extends StreamSpec(UnboundedMailboxConfig) { val settings = ActorMaterializerSettings(system).withDispatcher("akka.actor.default-dispatcher") - implicit val materializer = ActorMaterializer(settings) + implicit val materializer: ActorMaterializer = ActorMaterializer(settings) val fs = Jimfs.newFileSystem("FileSourceSpec", Configuration.unix()) diff --git a/akka-stream-tests/src/test/scala/akka/stream/io/InputStreamSourceSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/io/InputStreamSourceSpec.scala index d72a503eae..db9cf62f5b 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/io/InputStreamSourceSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/io/InputStreamSourceSpec.scala @@ -23,7 +23,7 @@ import com.github.ghik.silencer.silent class InputStreamSourceSpec extends StreamSpec(UnboundedMailboxConfig) { val settings = ActorMaterializerSettings(system).withDispatcher("akka.actor.default-dispatcher") - implicit val materializer = ActorMaterializer(settings) + implicit val materializer: ActorMaterializer = ActorMaterializer(settings) private def inputStreamFor(bytes: Array[Byte]): InputStream = new ByteArrayInputStream(bytes) diff --git a/akka-stream-tests/src/test/scala/akka/stream/io/OutputStreamSinkSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/io/OutputStreamSinkSpec.scala index 19a4f7216b..832265823e 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/io/OutputStreamSinkSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/io/OutputStreamSinkSpec.scala @@ -23,7 +23,7 @@ import scala.util.Success class OutputStreamSinkSpec extends StreamSpec(UnboundedMailboxConfig) with ScalaFutures { val settings = ActorMaterializerSettings(system).withDispatcher("akka.actor.default-dispatcher") - implicit val materializer = ActorMaterializer(settings) + implicit val materializer: ActorMaterializer = ActorMaterializer(settings) "OutputStreamSink" must { "write bytes to void OutputStream" in assertAllStagesStopped { diff --git a/akka-stream-tests/src/test/scala/akka/stream/io/compression/CodecSpecSupport.scala b/akka-stream-tests/src/test/scala/akka/stream/io/compression/CodecSpecSupport.scala index bce130c89b..d11e8030e3 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/io/compression/CodecSpecSupport.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/io/compression/CodecSpecSupport.scala @@ -73,7 +73,7 @@ est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscin "\r\n", "\n") - implicit val system = ActorSystem(getClass.getSimpleName) + implicit val system: ActorSystem = ActorSystem(getClass.getSimpleName) override def afterAll() = TestKit.shutdownActorSystem(system) } diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/AttributesSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/AttributesSpec.scala index a50f4d892a..a42eb47220 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/AttributesSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/AttributesSpec.scala @@ -125,7 +125,7 @@ class AttributesSpec val settings = ActorMaterializerSettings(system).withInputBuffer(initialSize = 2, maxSize = 16) - implicit val materializer = ActorMaterializer(settings) + implicit val materializer: ActorMaterializer = ActorMaterializer(settings) "an attributes instance" must { diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowFoldAsyncSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowFoldAsyncSpec.scala index 390caa5018..efe8f981c8 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowFoldAsyncSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowFoldAsyncSpec.scala @@ -19,10 +19,11 @@ import scala.concurrent.duration._ import scala.concurrent.Await import scala.concurrent.Future import scala.util.control.NoStackTrace +import scala.concurrent.ExecutionContextExecutor class FlowFoldAsyncSpec extends StreamSpec { - implicit def ec = system.dispatcher + implicit def ec: ExecutionContextExecutor = system.dispatcher val timeout = Timeout(3.seconds) "A FoldAsync" must { diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowJoinSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowJoinSpec.scala index 1a06683879..a23c212957 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowJoinSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowJoinSpec.scala @@ -17,7 +17,7 @@ class FlowJoinSpec extends StreamSpec(""" akka.stream.materializer.initial-input-buffer-size = 2 """) { - implicit val defaultPatience = + implicit val defaultPatience: PatienceConfig = PatienceConfig(timeout = Span(2, Seconds), interval = Span(200, Millis)) "A Flow using join" must { diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowRecoverWithSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowRecoverWithSpec.scala index efcd5266f7..6c45005e10 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowRecoverWithSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowRecoverWithSpec.scala @@ -19,7 +19,7 @@ class FlowRecoverWithSpec extends StreamSpec { val settings = ActorMaterializerSettings(system).withInputBuffer(initialSize = 1, maxSize = 1) - implicit val materializer = ActorMaterializer(settings) + implicit val materializer: ActorMaterializer = ActorMaterializer(settings) val ex = new RuntimeException("ex") with NoStackTrace diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowScanAsyncSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowScanAsyncSpec.scala index 9f4ddd2cc9..d7008e4bd6 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowScanAsyncSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowScanAsyncSpec.scala @@ -19,10 +19,11 @@ import scala.concurrent.Future import scala.concurrent.Promise import scala.util.Failure import org.scalatest.matchers.should.Matchers +import scala.concurrent.ExecutionContextExecutor class FlowScanAsyncSpec extends StreamSpec with Matchers { - implicit val executionContext = system.dispatcher + implicit val executionContext: ExecutionContextExecutor = system.dispatcher "A ScanAsync" must { diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSlidingSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSlidingSpec.scala index 6f57edd33b..a477286056 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSlidingSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSlidingSpec.scala @@ -17,7 +17,7 @@ class FlowSlidingSpec extends StreamSpec with ScalaCheckPropertyChecks { import system.dispatcher val settings = ActorMaterializerSettings(system).withInputBuffer(initialSize = 2, maxSize = 16) - implicit val materializer = ActorMaterializer(settings) + implicit val materializer: ActorMaterializer = ActorMaterializer(settings) "Sliding" must { import org.scalacheck.Shrink.shrinkAny diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSpec.scala index d87e5a3cc6..6dff6ab8e9 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSpec.scala @@ -40,7 +40,7 @@ class FlowSpec extends StreamSpec(ConfigFactory.parseString("akka.actor.debug.re val settings = ActorMaterializerSettings(system).withInputBuffer(initialSize = 2, maxSize = 2) - implicit val materializer = ActorMaterializer(settings) + implicit val materializer: ActorMaterializer = ActorMaterializer(settings) val identity: Flow[Any, Any, NotUsed] => Flow[Any, Any, NotUsed] = in => in.map(e => e) val identity2: Flow[Any, Any, NotUsed] => Flow[Any, Any, NotUsed] = in => identity(in) diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphBackedFlowSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphBackedFlowSpec.scala index c423ef93c0..0dee4cd596 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphBackedFlowSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphBackedFlowSpec.scala @@ -44,7 +44,7 @@ class GraphFlowSpec extends StreamSpec { val settings = ActorMaterializerSettings(system).withInputBuffer(initialSize = 2, maxSize = 16) - implicit val materializer = ActorMaterializer(settings) + implicit val materializer: ActorMaterializer = ActorMaterializer(settings) def validateProbe(probe: TestSubscriber.ManualProbe[Int], requests: Int, result: Set[Int]): Unit = { val subscription = probe.expectSubscription() diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphMergeSortedSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphMergeSortedSpec.scala index 89504aa9fc..d3d19ac200 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphMergeSortedSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphMergeSortedSpec.scala @@ -24,7 +24,8 @@ class GraphMergeSortedSpec extends TwoStreamsSetup with ScalaCheckPropertyChecks override def out: Outlet[Outputs] = merge.out } - implicit def noShrink[T] = Shrink[T](_ => Stream.empty) // do not shrink failures, it only destroys evidence + implicit def noShrink[T]: Shrink[T] = + Shrink[T](_ => Stream.empty) // do not shrink failures, it only destroys evidence "MergeSorted" must { diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/LastSinkSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/LastSinkSpec.scala index a614a0a8c3..0567105456 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/LastSinkSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/LastSinkSpec.scala @@ -10,10 +10,11 @@ import akka.stream.testkit.scaladsl.StreamTestKit._ import scala.concurrent.duration._ import scala.concurrent.Await import scala.concurrent.Future +import scala.concurrent.ExecutionContextExecutor class LastSinkSpec extends StreamSpec with ScriptedTest { - implicit val ec = system.dispatcher + implicit val ec: ExecutionContextExecutor = system.dispatcher "A Flow with Sink.last" must { diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/QueueSinkSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/QueueSinkSpec.scala index cfa5fc352e..de40efe0c7 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/QueueSinkSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/QueueSinkSpec.scala @@ -16,9 +16,10 @@ import scala.concurrent.Await import scala.concurrent.Promise import scala.concurrent.duration._ import scala.util.control.NoStackTrace +import scala.concurrent.ExecutionContextExecutor class QueueSinkSpec extends StreamSpec { - implicit val ec = system.dispatcher + implicit val ec: ExecutionContextExecutor = system.dispatcher val ex = new RuntimeException("ex") with NoStackTrace diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/QueueSourceSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/QueueSourceSpec.scala index 6541c7a042..910f8c74a6 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/QueueSourceSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/QueueSourceSpec.scala @@ -22,11 +22,11 @@ import scala.concurrent._ import scala.concurrent.duration._ class QueueSourceSpec extends StreamSpec { - implicit val ec = system.dispatcher + implicit val ec: ExecutionContextExecutor = system.dispatcher val pause = 300.millis // more frequent checks than defaults from AkkaSpec - implicit val testPatience = + implicit val testPatience: PatienceConfig = PatienceConfig(testKitSettings.DefaultTimeout.duration, Span(5, org.scalatest.time.Millis)) def assertSuccess(f: Future[QueueOfferResult]): Unit = { diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/SourceSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/SourceSpec.scala index 6d2364cf1f..c7249670c5 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/SourceSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/SourceSpec.scala @@ -26,7 +26,7 @@ import scala.collection.immutable @silent // tests assigning to typed val class SourceSpec extends StreamSpec with DefaultTimeout { - implicit val config = PatienceConfig(timeout = Span(timeout.duration.toMillis, Millis)) + implicit val config: PatienceConfig = PatienceConfig(timeout = Span(timeout.duration.toMillis, Millis)) "Single Source" must { diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/StreamConvertersSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/StreamConvertersSpec.scala index 72d0ccbcce..7011e34bfb 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/StreamConvertersSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/StreamConvertersSpec.scala @@ -28,7 +28,7 @@ import scala.concurrent.duration._ class StreamConvertersSpec extends StreamSpec with DefaultTimeout { - implicit val config = PatienceConfig(timeout = Span(timeout.duration.toMillis, Millis)) + implicit val config: PatienceConfig = PatienceConfig(timeout = Span(timeout.duration.toMillis, Millis)) "Java Stream source" must { import java.util.stream.IntStream diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/TakeLastSinkSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/TakeLastSinkSpec.scala index a77208d201..b686bac561 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/TakeLastSinkSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/TakeLastSinkSpec.scala @@ -16,7 +16,7 @@ class TakeLastSinkSpec extends StreamSpec { val settings = ActorMaterializerSettings(system).withInputBuffer(initialSize = 2, maxSize = 16) - implicit val mat = ActorMaterializer(settings) + implicit val mat: ActorMaterializer = ActorMaterializer(settings) "Sink.takeLast" must { "return the last 3 elements" in { diff --git a/akka-stream/src/main/scala/akka/stream/impl/ActorMaterializerImpl.scala b/akka-stream/src/main/scala/akka/stream/impl/ActorMaterializerImpl.scala index 8c67e78274..acc6768ff4 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/ActorMaterializerImpl.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/ActorMaterializerImpl.scala @@ -225,7 +225,7 @@ private[akka] class SubFusingActorMaterializerImpl( */ @InternalApi private[akka] class StreamSupervisor(haveShutDown: AtomicBoolean) extends Actor { import akka.stream.impl.StreamSupervisor._ - implicit val ec = context.dispatcher + implicit val ec: ExecutionContextExecutor = context.dispatcher override def supervisorStrategy: SupervisorStrategy = SupervisorStrategy.stoppingStrategy def receive: Receive = { diff --git a/akka-testkit/src/main/scala/akka/testkit/TestKit.scala b/akka-testkit/src/main/scala/akka/testkit/TestKit.scala index 566485c3fa..c2043b2272 100644 --- a/akka-testkit/src/main/scala/akka/testkit/TestKit.scala +++ b/akka-testkit/src/main/scala/akka/testkit/TestKit.scala @@ -964,7 +964,7 @@ trait TestKitBase { * @since 1.1 */ @silent // 'early initializers' are deprecated on 2.13 and will be replaced with trait parameters on 2.14. https://github.com/akka/akka/issues/26753 -class TestKit(_system: ActorSystem) extends { implicit val system = _system } with TestKitBase +class TestKit(_system: ActorSystem) extends { implicit val system: ActorSystem = _system } with TestKitBase object TestKit { @@ -1071,7 +1071,7 @@ object TestProbe { } trait ImplicitSender { this: TestKitBase => - implicit def self = testActor + implicit def self: ActorRef = testActor } trait DefaultTimeout { this: TestKitBase => diff --git a/akka-testkit/src/test/scala/akka/testkit/AkkaSpec.scala b/akka-testkit/src/test/scala/akka/testkit/AkkaSpec.scala index 6610e726db..79ea17802e 100644 --- a/akka-testkit/src/test/scala/akka/testkit/AkkaSpec.scala +++ b/akka-testkit/src/test/scala/akka/testkit/AkkaSpec.scala @@ -102,7 +102,7 @@ abstract class AkkaSpec(_system: ActorSystem) with TypeCheckedTripleEquals with ScalaFutures { - implicit val patience = PatienceConfig(testKitSettings.DefaultTimeout.duration, Span(100, Millis)) + implicit val patience: PatienceConfig = PatienceConfig(testKitSettings.DefaultTimeout.duration, Span(100, Millis)) def this(config: Config) = this( diff --git a/akka-testkit/src/test/scala/akka/testkit/DefaultTimeoutSpec.scala b/akka-testkit/src/test/scala/akka/testkit/DefaultTimeoutSpec.scala index 88894c153a..8ad409015a 100644 --- a/akka-testkit/src/test/scala/akka/testkit/DefaultTimeoutSpec.scala +++ b/akka-testkit/src/test/scala/akka/testkit/DefaultTimeoutSpec.scala @@ -11,7 +11,7 @@ import org.scalatest.wordspec.AnyWordSpec class DefaultTimeoutSpec extends AnyWordSpec with Matchers with BeforeAndAfterAll with TestKitBase with DefaultTimeout { - implicit lazy val system = ActorSystem("AkkaCustomSpec") + implicit lazy val system: ActorSystem = ActorSystem("AkkaCustomSpec") override def afterAll = system.terminate diff --git a/akka-testkit/src/test/scala/akka/testkit/ImplicitSenderSpec.scala b/akka-testkit/src/test/scala/akka/testkit/ImplicitSenderSpec.scala index 5abbbe449e..640e6e44f6 100644 --- a/akka-testkit/src/test/scala/akka/testkit/ImplicitSenderSpec.scala +++ b/akka-testkit/src/test/scala/akka/testkit/ImplicitSenderSpec.scala @@ -11,7 +11,7 @@ import org.scalatest.wordspec.AnyWordSpec class ImplicitSenderSpec extends AnyWordSpec with Matchers with BeforeAndAfterAll with TestKitBase with ImplicitSender { - implicit lazy val system = ActorSystem("AkkaCustomSpec") + implicit lazy val system: ActorSystem = ActorSystem("AkkaCustomSpec") override def afterAll = system.terminate