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

Uncomment ConstantRateEntityRecoveryStrategySpec

Browse source
This commit is contained in:
Christopher Batey 2018-11-15 16:48:43 +00:00
parent 40649151d0
commit 6c279aa271
1 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-cluster-sharding/src/test/scala/akka/cluster/sharding/ConstantRateEntityRecoveryStrategySpec.scala
View file

@ -4,14 +4,18 @@
package akka.cluster.sharding package akka.cluster.sharding
import akka.testkit.AkkaSpec import akka.cluster.sharding.ShardRegion.EntityId
import akka.testkit.{ AkkaSpec, TimingTest }
import scala.concurrent.{ Await, Future }
import scala.concurrent.duration._
class ConstantRateEntityRecoveryStrategySpec extends AkkaSpec { class ConstantRateEntityRecoveryStrategySpec extends AkkaSpec {
/*
val strategy = EntityRecoveryStrategy.constantStrategy(system, 1.second, 2) val strategy = EntityRecoveryStrategy.constantStrategy(system, 1.second, 2)
"ConstantRateEntityRecoveryStrategy" must { "ConstantRateEntityRecoveryStrategy" must {
"recover entities" taggedAs TimingTest in { "recover entities" taggedAs TimingTest in {
import system.dispatcher
val entities = Set[EntityId]("1", "2", "3", "4", "5") val entities = Set[EntityId]("1", "2", "3", "4", "5")
val startTime = System.nanoTime() val startTime = System.nanoTime()
val resultWithTimes = strategy.recoverEntities(entities).map( val resultWithTimes = strategy.recoverEntities(entities).map(
@ -40,5 +44,4 @@ class ConstantRateEntityRecoveryStrategySpec extends AkkaSpec {
result.size should ===(0) result.size should ===(0)
} }
} }
*/
} }