Skip to content

Commit 7dbfc94

Browse files
harden ReliableDeliveryShardingSpecs (#6747)
1 parent c0e4512 commit 7dbfc94

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/contrib/cluster/Akka.Cluster.Sharding.Tests/Delivery/ReliableDeliveryShardingSpec.cs

+2-2
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ public async Task ReliableDelivery_with_Sharding_must_illustrate_Sharding_usage(
8686
$"producer-{_idCount}");
8787

8888
// expecting 3 end messages, one for each entity: "entity-0", "entity-1", "entity-2"
89-
consumerEndProbe.ReceiveN(3, TimeSpan.FromSeconds(15));
89+
await consumerEndProbe.ReceiveNAsync(3, TimeSpan.FromSeconds(25)).ToListAsync();
9090
}
9191

9292
[Fact]
@@ -128,7 +128,7 @@ public async Task ReliableDelivery_with_Sharding_must_illustrate_Sharding_usage_
128128
$"p2-{_idCount}");
129129

130130
// expecting 3 end messages, one for each entity: "entity-0", "entity-1", "entity-2"
131-
var endMessages = consumerEndProbe.ReceiveN(3, TimeSpan.FromSeconds(15));
131+
var endMessages = await consumerEndProbe.ReceiveNAsync(3, TimeSpan.FromSeconds(25)).ToListAsync();
132132

133133
var producerIds = endMessages.Cast<Collected>().SelectMany(c => c.ProducerIds).ToList();
134134
producerIds

0 commit comments

Comments
 (0)