raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Merge pull request #25416 from chbatey/nits

Browse source 
Remove various compiler warnings
This commit is contained in:
Patrik Nordwall 2018-08-23 11:36:57 +02:00 • committed by GitHub
commit b9aecb7f5a
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
11 changed files with 3 additions and 32 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor-typed-tests/src/test/scala/akka/actor/typed/BehaviorSpec.scala
View file

@ -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))

3
akka-actor-typed-tests/src/test/scala/akka/actor/typed/OrElseSpec.scala
View file

@ -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

1
akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/MessageAdapterSpec.scala
View file

@ -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

5
akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/StopSpec.scala
View file

@ -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

2
akka-actor-typed/src/main/scala/akka/actor/typed/SupervisorStrategy.scala
View file

@ -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

1
akka-actor-typed/src/main/scala/akka/actor/typed/internal/Restarter.scala
View file

@ -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

1
akka-actor-typed/src/main/scala/akka/actor/typed/internal/StashBufferImpl.scala
View file

@ -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

1
akka-actor-typed/src/main/scala/akka/actor/typed/internal/adapter/ActorAdapter.scala
View file

@ -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

2
akka-remote/src/main/scala/akka/remote/artery/ImmutableLongMap.scala
View file

@ -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
}
/**

11
akka-remote/src/main/scala/akka/remote/transport/netty/SSLEngineProvider.scala
View file

@ -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

6
akka-stream/src/main/scala/akka/stream/javadsl/Graph.scala
View file

@ -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