diff --git a/src/core/Akka.Cluster.Tests/Routing/ClusterRouterAsk1343BugFixSpec.cs b/src/core/Akka.Cluster.Tests/Routing/ClusterRouterAsk1343BugFixSpec.cs index b38513fdb9e..eeb62ed9b18 100644 --- a/src/core/Akka.Cluster.Tests/Routing/ClusterRouterAsk1343BugFixSpec.cs +++ b/src/core/Akka.Cluster.Tests/Routing/ClusterRouterAsk1343BugFixSpec.cs @@ -68,7 +68,7 @@ public ClusterRouterAsk1343BugFixSpec() { } - + [Fact] public async Task Should_Ask_Clustered_Pool_Router_and_forward_ask_to_routee() { @@ -76,7 +76,7 @@ public async Task Should_Ask_Clustered_Pool_Router_and_forward_ask_to_routee() Assert.IsType(router); var result = await router.Ask("foo"); - ExpectMsg().ShouldBe(result); + (await ExpectMsgAsync()).ShouldBe(result); } [Fact] @@ -87,7 +87,7 @@ public async Task Should_Ask_Clustered_Group_Router_and_forward_ask_to_routee() Assert.IsType(router); var result = await router.Ask("foo"); - ExpectMsg().ShouldBe(result); + (await ExpectMsgAsync()).ShouldBe(result); } [Fact]