harden ReliableDeliveryShardingSpecs (#6747)

akkadotnet · May 9, 2023 · 7dbfc94 · 7dbfc94
1 parent c0e4512
commit 7dbfc94
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/contrib/cluster/Akka.Cluster.Sharding.Tests/Delivery/ReliableDeliveryShardingSpec.cs b/src/contrib/cluster/Akka.Cluster.Sharding.Tests/Delivery/ReliableDeliveryShardingSpec.cs
@@ -86,7 +86,7 @@ public async Task ReliableDelivery_with_Sharding_must_illustrate_Sharding_usage(
             $"producer-{_idCount}");
 
         // expecting 3 end messages, one for each entity: "entity-0", "entity-1", "entity-2"
-        consumerEndProbe.ReceiveN(3, TimeSpan.FromSeconds(15));
+        await consumerEndProbe.ReceiveNAsync(3, TimeSpan.FromSeconds(25)).ToListAsync();
     }
 
     [Fact]
@@ -128,7 +128,7 @@ public async Task ReliableDelivery_with_Sharding_must_illustrate_Sharding_usage_
             $"p2-{_idCount}");
 
         // expecting 3 end messages, one for each entity: "entity-0", "entity-1", "entity-2"
-        var endMessages = consumerEndProbe.ReceiveN(3, TimeSpan.FromSeconds(15));
+        var endMessages = await consumerEndProbe.ReceiveNAsync(3, TimeSpan.FromSeconds(25)).ToListAsync();
 
         var producerIds = endMessages.Cast<Collected>().SelectMany(c => c.ProducerIds).ToList();
         producerIds