fix: immutable object domain

apache · Sep 23, 2023 · 581da0c · 581da0c
1 parent 3ef14e9
commit 581da0c
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/DeadLetterSpec.scala b/actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/DeadLetterSpec.scala
@@ -44,9 +44,8 @@ sealed trait WorkerCommand
 case class WorkerMultiply(a: Int, b: Int, replyTo: ActorRef[WorkerResult]) extends WorkerCommand
 case class WorkerResult(num: Int) extends WorkerCommand
 
-class ManualTerminatedTestSetup(workerCnt: Int) {
+class ManualTerminatedTestSetup(val workerLatch: CountDownLatch) {
   implicit val timeout: Timeout = 10.millis
-  val workerLatch = new CountDownLatch(workerCnt)
 
   def forwardBehavior: Behavior[Command] =
     setup[Command] { context =>
@@ -91,7 +90,8 @@ class DeadLetterSpec extends ScalaTestWithActorTestKit(
 
   "DeadLetterActor" must {
 
-    "publish dead letter with recipient when context.ask terminated" in new ManualTerminatedTestSetup(workerCnt = 1) {
+    "publish dead letter with recipient when context.ask terminated" in new ManualTerminatedTestSetup(
+      workerLatch = new CountDownLatch(1)) {
       val deadLetterProbe = createDeadLetterProbe()
       val forwardRef = spawn(forwardBehavior)
       val workerRef = spawn(workerBehavior)
@@ -112,7 +112,8 @@ class DeadLetterSpec extends ScalaTestWithActorTestKit(
       deadLetter.recipient shouldNot equal(deadLettersRef)
     }
 
-    "publish dead letter with recipient when AskPattern timeout" in new ManualTerminatedTestSetup(workerCnt = 1) {
+    "publish dead letter with recipient when AskPattern timeout" in new ManualTerminatedTestSetup(
+      workerLatch = new CountDownLatch(1)) {
       val deadLetterProbe = createDeadLetterProbe()
       val workerRef = spawn(workerBehavior)