Skip to content

Commit faaf9b2

Browse files
authored
[CS1998] ClusterHeartbeatReceiverSpec This async method lacks await operators (#6699)
1 parent dcdf45f commit faaf9b2

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

src/core/Akka.Cluster.Tests/ClusterHeartbeatReceiverSpec.cs

+5-4
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
//-----------------------------------------------------------------------
77

88
using System;
9+
using System.Threading;
910
using System.Threading.Tasks;
1011
using Akka.Actor;
1112
using Akka.Configuration;
@@ -58,8 +59,8 @@ public async Task ClusterHeartbeatReceiver_should_write_correct_debug_messages_o
5859
{
5960
var heartbeater = Sys.ActorOf(ClusterHeartbeatReceiver.Props(Cluster.Get(Sys)));
6061

61-
EventFilter.Debug(contains: "- Sequence number [2]")
62-
.ExpectOne(() => heartbeater.Tell(new Heartbeat(Cluster.Get(Sys).SelfAddress, 2, 3)));
62+
await EventFilter.Debug(contains: "- Sequence number [2]")
63+
.ExpectOneAsync(() => { heartbeater.Tell(new Heartbeat(Cluster.Get(Sys).SelfAddress, 2, 3)); return Task.CompletedTask; });
6364
}
6465

6566
[Fact]
@@ -68,8 +69,8 @@ public async Task ClusterHeartbeatSender_should_write_correct_debug_messages_on_
6869
var heartbeater = Sys.ActorOf(Props.Create(() => new ClusterHeartbeatSender(Cluster.Get(Sys))));
6970
heartbeater.Tell(new ClusterEvent.CurrentClusterState());
7071

71-
EventFilter.Debug(contains: "- Sequence number [2] - Creation time [00:00:03]")
72-
.ExpectOne(() => heartbeater.Tell(new HeartbeatRsp(Cluster.Get(Sys).SelfUniqueAddress, 2, 3000000000)));
72+
await EventFilter.Debug(contains: "- Sequence number [2] - Creation time [00:00:03]")
73+
.ExpectOneAsync(() => { heartbeater.Tell(new HeartbeatRsp(Cluster.Get(Sys).SelfUniqueAddress, 2, 3000000000)); return Task.CompletedTask; });
7374
}
7475
}
7576
}

0 commit comments

Comments
 (0)