Convert Akka.Remote.Tests to async - Serialization.SerializationTrans…

…portInformationSpec (#5904)
akkadotnet · Apr 29, 2022 · b231fad · b231fad
1 parent 06990ec
commit b231fad
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/src/core/Akka.Remote.Tests/Serialization/SerializationTransportInformationSpec.cs b/src/core/Akka.Remote.Tests/Serialization/SerializationTransportInformationSpec.cs
@@ -115,7 +115,7 @@ private void VerifyTransportInfo()
 
     public abstract class AbstractSerializationTransportInformationSpec : AkkaSpec
     {
-        public static readonly Config Config = @"
+        private static readonly Config Config = @"
             akka {
                 loglevel = info
                 actor
@@ -151,7 +151,7 @@ protected AbstractSerializationTransportInformationSpec(Config config, ITestOutp
         public Address System2Address => RARP.For(System2).Provider.DefaultAddress;
 
         [Fact]
-        public void Serialization_of_ActorRef_in_remote_message_must_resolve_Address()
+        public async Task Serialization_of_ActorRef_in_remote_message_must_resolve_Address()
         {
             System2.ActorOf(act =>
             {
@@ -160,28 +160,28 @@ public void Serialization_of_ActorRef_in_remote_message_must_resolve_Address()
 
             var echoSel = Sys.ActorSelection(new RootActorPath(System2Address) / "user" / "echo");
             echoSel.Tell(new Identify(1));
-            var echo = ExpectMsg<ActorIdentity>().Subject;
+            var echo = (await ExpectMsgAsync<ActorIdentity>()).Subject;
 
             echo.Tell(new TestMessage(TestActor, echo));
-            var t1 = ExpectMsg<TestMessage>();
+            var t1 = await ExpectMsgAsync<TestMessage>();
             t1.From.Should().Be(TestActor);
             t1.To.Should().Be(echo);
 
             echo.Tell(new JsonSerTestMessage(TestActor, echo));
-            var t2 = ExpectMsg<JsonSerTestMessage>();
+            var t2 = await ExpectMsgAsync<JsonSerTestMessage>();
             t2.From.Should().Be(TestActor);
             t2.To.Should().Be(echo);
 
             echo.Tell(TestActor);
-            ExpectMsg(TestActor);
+            await ExpectMsgAsync(TestActor);
 
             echo.Tell(echo);
-            ExpectMsg(echo);
+            await ExpectMsgAsync(echo);
         }
 
         protected override async Task AfterAllAsync()
         {
-            await ShutdownAsync(System2, verifySystemShutdown: true);
+            await ShutdownAsync(System2);
             await base.AfterAllAsync();
         }
     }