Reducing sleep time for ActorPoolSpec for typed actors and removing defaultSupervisor from Props
This commit is contained in:
parent
fd130d0310
commit
48dbfda255
2 changed files with 2 additions and 2 deletions
|
|
@ -345,7 +345,7 @@ class ActorPoolSpec extends AkkaSpec {
|
||||||
def receive = _route
|
def receive = _route
|
||||||
}, Props().withTimeout(10 seconds).withFaultHandler(faultHandler))
|
}, Props().withTimeout(10 seconds).withFaultHandler(faultHandler))
|
||||||
|
|
||||||
val results = for (i ← 1 to 20) yield (i, pool.sq(i, 100))
|
val results = for (i ← 1 to 20) yield (i, pool.sq(i, 10))
|
||||||
|
|
||||||
for ((i, r) ← results) {
|
for ((i, r) ← results) {
|
||||||
val value = r.get
|
val value = r.get
|
||||||
|
|
|
||||||
|
|
@ -28,7 +28,7 @@ object Props {
|
||||||
case _ ⇒ Escalate
|
case _ ⇒ Escalate
|
||||||
}
|
}
|
||||||
final val defaultFaultHandler: FaultHandlingStrategy = OneForOneStrategy(defaultDecider, None, None)
|
final val defaultFaultHandler: FaultHandlingStrategy = OneForOneStrategy(defaultDecider, None, None)
|
||||||
final val defaultSupervisor: Option[ActorRef] = None
|
|
||||||
final val noHotSwap: Stack[Actor.Receive] = Stack.empty
|
final val noHotSwap: Stack[Actor.Receive] = Stack.empty
|
||||||
final val randomAddress: String = ""
|
final val randomAddress: String = ""
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue