Port Akka.Tests.Loggers tests to async/await - LoggerSpec (#5798)

Co-authored-by: Gregorius Soedharmo <[email protected]>

Author: eaba

src/core/Akka.Tests/Loggers/LoggerSpec.cs

@@ -38,31 +38,31 @@ public async Task TestOutputLogger_WithBadFormattingMustNotThrow()
             Sys.EventStream.Subscribe(TestActor, typeof(LogEvent));
 
             Sys.Log.Error(new FakeException("BOOM"), Case.t, Case.p);
-            events.Add(ExpectMsg<Error>());
-            events.Add(ExpectMsg<Error>());
+            events.Add(await ExpectMsgAsync<Error>());
+            events.Add(await ExpectMsgAsync<Error>());
 
             events.All(e => e is Error).Should().BeTrue();
             events.Select(e => e.Cause).Any(c => c is FakeException).Should().BeTrue();
             events.Select(e => e.Cause).Any(c => c is AggregateException).Should().BeTrue();
 
             events.Clear();
             Sys.Log.Warning(Case.t, Case.p);
-            events.Add(ExpectMsg<LogEvent>());
-            events.Add(ExpectMsg<LogEvent>());
+            events.Add(await ExpectMsgAsync<LogEvent>());
+            events.Add(await ExpectMsgAsync<LogEvent>());
             events.Any(e => e is Warning).Should().BeTrue();
             events.First(e => e is Error).Cause.Should().BeOfType<FormatException>();
 
             events.Clear();
             Sys.Log.Info(Case.t, Case.p);
-            events.Add(ExpectMsg<LogEvent>());
-            events.Add(ExpectMsg<LogEvent>());
+            events.Add(await ExpectMsgAsync<LogEvent>());
+            events.Add(await ExpectMsgAsync<LogEvent>());
             events.Any(e => e is Info).Should().BeTrue();
             events.First(e => e is Error).Cause.Should().BeOfType<FormatException>();
 
             events.Clear();
             Sys.Log.Debug(Case.t, Case.p);
-            events.Add(ExpectMsg<LogEvent>());
-            events.Add(ExpectMsg<LogEvent>());
+            events.Add(await ExpectMsgAsync<LogEvent>());
+            events.Add(await ExpectMsgAsync<LogEvent>());
             events.Any(e => e is Debug).Should().BeTrue();
             events.First(e => e is Error).Cause.Should().BeOfType<FormatException>();
         }
@@ -77,16 +77,16 @@ public async Task DefaultLogger_WithBadFormattingMustNotThrow()
             sys2.EventStream.Subscribe(probe, typeof(LogEvent));
 
             sys2.Log.Error(new FakeException("BOOM"), Case.t, Case.p);
-            probe.ExpectMsg<Error>().Cause.Should().BeOfType<FakeException>();
+            (await probe.ExpectMsgAsync<Error>()).Cause.Should().BeOfType<FakeException>();
 
             sys2.Log.Warning(Case.t, Case.p);
-            probe.ExpectMsg<Warning>();
+            await probe.ExpectMsgAsync<Warning>();
 
             sys2.Log.Info(Case.t, Case.p);
-            probe.ExpectMsg<Info>();
+            await probe.ExpectMsgAsync<Info>();
 
             sys2.Log.Debug(Case.t, Case.p);
-            probe.ExpectMsg<Debug>();
+            await probe.ExpectMsgAsync<Debug>();
 
             await sys2.Terminate();
         }
@@ -101,16 +101,16 @@ public async Task StandardOutLogger_WithBadFormattingMustNotThrow()
             sys2.EventStream.Subscribe(probe, typeof(LogEvent));
 
             sys2.Log.Error(new FakeException("BOOM"), Case.t, Case.p);
-            probe.ExpectMsg<Error>().Cause.Should().BeOfType<FakeException>();
+            (await probe.ExpectMsgAsync<Error>()).Cause.Should().BeOfType<FakeException>();
 
             sys2.Log.Warning(Case.t, Case.p);
-            probe.ExpectMsg<Warning>();
+            await probe.ExpectMsgAsync<Warning>();
 
             sys2.Log.Info(Case.t, Case.p);
-            probe.ExpectMsg<Info>();
+            await probe.ExpectMsgAsync<Info>();
 
             sys2.Log.Debug(Case.t, Case.p);
-            probe.ExpectMsg<Debug>();
+            await probe.ExpectMsgAsync<Debug>();
 
             await sys2.Terminate();
         }