🚨test: Set short timeout values to expect... that is in 'awaitAssert'

Author: negokaz

src/multi-jvm/scala/lerna/akka/entityreplication/RaftActorCompactionSpec.scala

@@ -153,7 +153,7 @@ class RaftActorCompactionSpec extends MultiNodeSpec(RaftActorCompactionSpecConfi
       runOn(node1, node2, node3) {
         awaitAssert {
           replicationActor(myself) ! DummyReplicationActor.GetState(entityId)
-          expectMsg(DummyReplicationActor.State(1))
+          expectMsg(max = 1.second, DummyReplicationActor.State(1))
         }
       }
       enterBarrier("all ReplicationActor applied an event")
@@ -178,14 +178,14 @@ class RaftActorCompactionSpec extends MultiNodeSpec(RaftActorCompactionSpecConfi
         // ReplicationActor which has not been isolated applied all events
         awaitAssert {
           replicationActor(myself) ! DummyReplicationActor.GetState(entityId)
-          expectMsg(DummyReplicationActor.State(4))
+          expectMsg(max = 1.second, DummyReplicationActor.State(4))
         }
       }
       runOn(node3) {
         // ReplicationActor which has been isolated did not apply any events
         awaitAssert {
           replicationActor(myself) ! DummyReplicationActor.GetState(entityId)
-          expectMsg(DummyReplicationActor.State(1))
+          expectMsg(max = 1.second, DummyReplicationActor.State(1))
         }
       }
       enterBarrier("ReplicationActor which has not been isolated applied all events")

src/multi-jvm/scala/lerna/akka/entityreplication/RaftEventSourcedSpec.scala

@@ -199,14 +199,14 @@ class RaftEventSourcedSpec extends MultiNodeSpec(RaftEventSourcedSpecConfig) wit
         awaitAssert(
           {
             clusterReplication ! DummyReplicationActor.Increment(entityId, requestId1, amount = 3)
-            expectMsgType[DummyReplicationActor.State].knownRequestId should contain(requestId1)
+            expectMsgType[DummyReplicationActor.State](max = 1.second).knownRequestId should contain(requestId1)
           },
           initializationTimeout,
         )
 
         awaitAssert {
           clusterReplication ! DummyReplicationActor.Increment(entityId, requestId2, amount = 10)
-          expectMsgType[DummyReplicationActor.State].knownRequestId should contain(requestId2)
+          expectMsgType[DummyReplicationActor.State](max = 1.second).knownRequestId should contain(requestId2)
         }
 
         val readJournal =

src/multi-jvm/scala/lerna/akka/entityreplication/ReplicationRegionSpec.scala

@@ -285,7 +285,7 @@ class ReplicationRegionSpec extends MultiNodeSpec(ReplicationRegionSpecConfig) w
         val replicationActorPath = s"/system/sharding/raft-shard-$typeName-$role/$clusterShard/$raftShardId/$entityId"
         awaitAssert {
           system.actorSelection(replicationActorPath) ! GetStatus(entityId)
-          expectMsg(Status(3))
+          expectMsg(max = 1.second, Status(3))
         }
       }
     }

src/multi-jvm/scala/lerna/akka/entityreplication/raft/RaftActorMultiNodeSpec.scala

@@ -654,6 +654,6 @@ class RaftActorMultiNodeSpec extends MultiNodeSpec(RaftActorSpecConfig) with STM
 
   protected def getState(raftActor: ActorRef): RaftState = {
     raftActor ! GetState
-    expectMsgType[RaftState]
+    expectMsgType[RaftState](max = 1.second)
   }
 }