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

Honor timeout parameter when stopping actors #30715 (#30717)

Browse source
This commit is contained in:
David Barrett 2021-09-27 16:37:54 +01:00 • committed by GitHub
parent 5f38eb297f
commit 46bae17854
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor-testkit-typed/src/main/scala/akka/actor/testkit/typed/scaladsl/ActorTestKit.scala
View file

@ -255,7 +255,7 @@ final class ActorTestKit private[akka] (
try { try {
Await.result(internalTestKitGuardian.ask { (x: ActorRef[ActorTestKitGuardian.Ack.type]) => Await.result(internalTestKitGuardian.ask { (x: ActorRef[ActorTestKitGuardian.Ack.type]) =>
ActorTestKitGuardian.StopActor(ref, x) ActorTestKitGuardian.StopActor(ref, x)
}, max) }(Timeout(max), scheduler), max)
} catch { } catch {
case _: TimeoutException => case _: TimeoutException =>
assert(false, s"timeout ($max) during stop() waiting for actor [${ref.path}] to stop") assert(false, s"timeout ($max) during stop() waiting for actor [${ref.path}] to stop")