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

Merge pull request #27978 from akka/wip-scala-2.12-simplifications-patriknw

Browse source 
small simplification since Scala 2.11 isn't supported
This commit is contained in:
Patrik Nordwall 2019-10-15 11:17:54 +02:00 • committed by GitHub
commit c83d04c1f8
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
5 changed files with 5 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-actor-typed/src/main/scala/akka/actor/typed/receptionist/Receptionist.scala
View file

@ -372,9 +372,7 @@ object Receptionist extends ExtensionId[Receptionist] {
object ReceptionistSetup { object ReceptionistSetup {
def apply[T <: Extension](createExtension: ActorSystem[_] => Receptionist): ReceptionistSetup = def apply[T <: Extension](createExtension: ActorSystem[_] => Receptionist): ReceptionistSetup =
new ReceptionistSetup(new java.util.function.Function[ActorSystem[_], Receptionist] { new ReceptionistSetup(createExtension(_))
override def apply(sys: ActorSystem[_]): Receptionist = createExtension(sys)
}) // TODO can be simplified when compiled only with Scala >= 2.12
} }

4
akka-cluster-sharding-typed/src/main/scala/akka/cluster/sharding/typed/scaladsl/ClusterSharding.scala
View file

@ -445,9 +445,7 @@ object EntityTypeKey {
object ClusterShardingSetup { object ClusterShardingSetup {
def apply[T <: Extension](createExtension: ActorSystem[_] => ClusterSharding): ClusterShardingSetup = def apply[T <: Extension](createExtension: ActorSystem[_] => ClusterSharding): ClusterShardingSetup =
new ClusterShardingSetup(new java.util.function.Function[ActorSystem[_], ClusterSharding] { new ClusterShardingSetup(createExtension(_))
override def apply(sys: ActorSystem[_]): ClusterSharding = createExtension(sys)
}) // TODO can be simplified when compiled only with Scala >= 2.12
} }

4
akka-cluster-typed/src/main/scala/akka/cluster/ddata/typed/javadsl/DistributedData.scala
View file

@ -99,9 +99,7 @@ abstract class DistributedData extends Extension {
object DistributedDataSetup { object DistributedDataSetup {
def apply[T <: Extension](createExtension: ActorSystem[_] => DistributedData): DistributedDataSetup = def apply[T <: Extension](createExtension: ActorSystem[_] => DistributedData): DistributedDataSetup =
new DistributedDataSetup(new java.util.function.Function[ActorSystem[_], DistributedData] { new DistributedDataSetup(createExtension(_))
override def apply(sys: ActorSystem[_]): DistributedData = createExtension(sys)
}) // TODO can be simplified when compiled only with Scala >= 2.12
} }

4
akka-cluster-typed/src/main/scala/akka/cluster/typed/Cluster.scala
View file

@ -194,9 +194,7 @@ abstract class Cluster extends Extension {
object ClusterSetup { object ClusterSetup {
def apply[T <: Extension](createExtension: ActorSystem[_] => Cluster): ClusterSetup = def apply[T <: Extension](createExtension: ActorSystem[_] => Cluster): ClusterSetup =
new ClusterSetup(new java.util.function.Function[ActorSystem[_], Cluster] { new ClusterSetup(createExtension(_))
override def apply(sys: ActorSystem[_]): Cluster = createExtension(sys)
}) // TODO can be simplified when compiled only with Scala >= 2.12
} }

4
akka-cluster-typed/src/main/scala/akka/cluster/typed/ClusterSingleton.scala
View file

@ -297,9 +297,7 @@ final class ClusterSingletonManagerSettings(
object ClusterSingletonSetup { object ClusterSingletonSetup {
def apply[T <: Extension](createExtension: ActorSystem[_] => ClusterSingleton): ClusterSingletonSetup = def apply[T <: Extension](createExtension: ActorSystem[_] => ClusterSingleton): ClusterSingletonSetup =
new ClusterSingletonSetup(new java.util.function.Function[ActorSystem[_], ClusterSingleton] { new ClusterSingletonSetup(createExtension(_))
override def apply(sys: ActorSystem[_]): ClusterSingleton = createExtension(sys)
}) // TODO can be simplified when compiled only with Scala >= 2.12
} }