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

Update ReplicatorMessageAdapter#subscribe (#31050)

Browse source 
The method was calling `unsubscribe` twice.
This commit is contained in:
Alexis Hernandez 2022-01-11 04:31:51 -07:00 • committed by GitHub
parent 221da34234
commit 04e22c3687
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 2 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -68,9 +68,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
def subscribe(key: Key[B], responseAdapter: akka.japi.function.Function[Replicator.SubscribeResponse[B], A]): Unit = {
// unsubscribe in case it's called more than once per key
unsubscribe(key)
changedMessageAdapters.get(key).foreach { subscriber =>
replicator ! Replicator.Unsubscribe(key, subscriber)
}
val replyTo: ActorRef[Replicator.SubscribeResponse[B]] =
context.messageAdapter(classOf[Replicator.SubscribeResponse[B]], responseAdapter)
changedMessageAdapters = changedMessageAdapters.updated(key, replyTo)

4
akka-cluster-typed/src/main/scala/akka/cluster/ddata/typed/scaladsl/ReplicatorMessageAdapter.scala
View file

@ -71,9 +71,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
def subscribe(key: Key[B], responseAdapter: Replicator.SubscribeResponse[B] => A): Unit = {
// unsubscribe in case it's called more than once per key
unsubscribe(key)
changedMessageAdapters.get(key).foreach { subscriber =>
replicator ! Replicator.Unsubscribe(key, subscriber)
}
val replyTo: ActorRef[Replicator.SubscribeResponse[B]] =
context.messageAdapter[Replicator.SubscribeResponse[B]](responseAdapter)
changedMessageAdapters = changedMessageAdapters.updated(key, replyTo)