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

fix akka-cluster-sharding-typed/test:compile (#26046)

Browse source 
Weird that CI didn't catch this
This commit is contained in:
Arnout Engelen 2018-12-05 11:30:38 +01:00 • committed by Christopher Batey
parent bf714dd72a
commit 7afd847758
1 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-cluster-sharding-typed/src/test/scala/akka/cluster/sharding/typed/scaladsl/ClusterShardingPersistenceSpec.scala
View file

@ -8,6 +8,7 @@ import java.util.concurrent.ConcurrentHashMap
import java.util.concurrent.CountDownLatch import java.util.concurrent.CountDownLatch
import java.util.concurrent.TimeUnit import java.util.concurrent.TimeUnit
import scala.concurrent.duration._
import scala.concurrent.ExecutionContext import scala.concurrent.ExecutionContext
import scala.concurrent.Future import scala.concurrent.Future
import scala.concurrent.Promise import scala.concurrent.Promise
@ -81,7 +82,7 @@ object ClusterShardingPersistenceSpec {
case cmd @ AddWithConfirmation(s) ⇒ case cmd @ AddWithConfirmation(s) ⇒
Effect.persist(s) Effect.persist(s)
.thenReply(cmd)(newState ⇒ Done) .thenReply(cmd)(_ ⇒ Done)
case Get(replyTo) ⇒ case Get(replyTo) ⇒
replyTo ! s"$entityId:$state" replyTo ! s"$entityId:$state"
@ -90,7 +91,7 @@ object ClusterShardingPersistenceSpec {
case cmd @ PassivateAndPersist(s) ⇒ case cmd @ PassivateAndPersist(s) ⇒
shard ! Passivate(ctx.self) shard ! Passivate(ctx.self)
Effect.persist(s) Effect.persist(s)
.thenReply(cmd)(newState ⇒ Done) .thenReply(cmd)(_ ⇒ Done)
case Echo(msg, replyTo) ⇒ case Echo(msg, replyTo) ⇒
Effect.none.thenRun(_ ⇒ replyTo ! msg) Effect.none.thenRun(_ ⇒ replyTo ! msg)