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

User Interger in javadsl function

Browse source
This commit is contained in:
Renato Cavalcanti 2020-06-12 21:27:27 +02:00
parent 4f2e82e5f6
commit b89cc4c417
No known key found for this signature in database
GPG key ID: C7F92AA2BCB77E03
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-cluster-sharding-typed/src/main/scala/akka/cluster/sharding/typed/internal/ShardedDaemonProcessImpl.scala
View file

@ -168,7 +168,7 @@ private[akka] final class ShardedDaemonProcessImpl(system: ActorSystem[_])
messageClass: Class[T],
name: String,
numberOfInstances: Int,
behaviorFactory: function.Function[Int, Behavior[T]],
behaviorFactory: function.Function[Integer, Behavior[T]],
stopMessage: T): Unit =
init(name, numberOfInstances, n => behaviorFactory(n), ShardedDaemonProcessSettings(system), Some(stopMessage))(
ClassTag(messageClass))

2
akka-cluster-sharding-typed/src/main/scala/akka/cluster/sharding/typed/javadsl/ShardedDaemonProcess.scala
View file

@ -56,7 +56,7 @@ abstract class ShardedDaemonProcess {
messageClass: Class[T],
name: String,
numberOfInstances: Int,
behaviorFactory: function.Function[Int, Behavior[T]],
behaviorFactory: function.Function[Integer, Behavior[T]],
stopMessage: T): Unit
/**