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

Merge pull request #25932 from chbatey/uncomment-test

Browse source 
Uncomment ConstantRateEntityRecoveryStrategySpec
This commit is contained in:
Patrik Nordwall 2018-11-18 20:03:09 +01:00 • committed by GitHub
commit caec209bf6
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
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
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 {
/*
val strategy = EntityRecoveryStrategy.constantStrategy(system, 1.second, 2)
"ConstantRateEntityRecoveryStrategy" must {
"recover entities" taggedAs TimingTest in {
import system.dispatcher
val entities = Set[EntityId]("1", "2", "3", "4", "5")
val startTime = System.nanoTime()
val resultWithTimes = strategy.recoverEntities(entities).map(
@ -40,5 +44,4 @@ class ConstantRateEntityRecoveryStrategySpec extends AkkaSpec {
result.size should ===(0)
}
}
*/
}