From 7afd84775873d64dbf949e039c865831b798724a Mon Sep 17 00:00:00 2001 From: Arnout Engelen Date: Wed, 5 Dec 2018 11:30:38 +0100 Subject: [PATCH] fix akka-cluster-sharding-typed/test:compile (#26046) Weird that CI didn't catch this --- .../typed/scaladsl/ClusterShardingPersistenceSpec.scala | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/akka-cluster-sharding-typed/src/test/scala/akka/cluster/sharding/typed/scaladsl/ClusterShardingPersistenceSpec.scala b/akka-cluster-sharding-typed/src/test/scala/akka/cluster/sharding/typed/scaladsl/ClusterShardingPersistenceSpec.scala index 256d43aadb..a3d59c7a77 100644 --- a/akka-cluster-sharding-typed/src/test/scala/akka/cluster/sharding/typed/scaladsl/ClusterShardingPersistenceSpec.scala +++ b/akka-cluster-sharding-typed/src/test/scala/akka/cluster/sharding/typed/scaladsl/ClusterShardingPersistenceSpec.scala @@ -8,6 +8,7 @@ import java.util.concurrent.ConcurrentHashMap import java.util.concurrent.CountDownLatch import java.util.concurrent.TimeUnit +import scala.concurrent.duration._ import scala.concurrent.ExecutionContext import scala.concurrent.Future import scala.concurrent.Promise @@ -81,7 +82,7 @@ object ClusterShardingPersistenceSpec { case cmd @ AddWithConfirmation(s) ⇒ Effect.persist(s) - .thenReply(cmd)(newState ⇒ Done) + .thenReply(cmd)(_ ⇒ Done) case Get(replyTo) ⇒ replyTo ! s"$entityId:$state" @@ -90,7 +91,7 @@ object ClusterShardingPersistenceSpec { case cmd @ PassivateAndPersist(s) ⇒ shard ! Passivate(ctx.self) Effect.persist(s) - .thenReply(cmd)(newState ⇒ Done) + .thenReply(cmd)(_ ⇒ Done) case Echo(msg, replyTo) ⇒ Effect.none.thenRun(_ ⇒ replyTo ! msg)