Block Xunit2 TestKit until unit test logger is ready (#6152)

Co-authored-by: Aaron Stannard <aaron@petabridge.com>
akkadotnet · Oct 6, 2022 · d683312 · d683312
1 parent 6655d63
commit d683312
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/contrib/testkits/Akka.TestKit.Xunit2/Internals/Loggers.cs b/src/contrib/testkits/Akka.TestKit.Xunit2/Internals/Loggers.cs
@@ -35,6 +35,7 @@ public TestOutputLogger(ITestOutputHelper output)
             Receive<InitializeLogger>(e =>
             {
                 e.LoggingBus.Subscribe(Self, typeof (LogEvent));
+                Sender.Tell(new LoggerInitialized());
             });
         }
 

diff --git a/src/contrib/testkits/Akka.TestKit.Xunit2/TestKit.cs b/src/contrib/testkits/Akka.TestKit.Xunit2/TestKit.cs
@@ -145,7 +145,8 @@ protected void InitializeLogger(ActorSystem system)
             {
                 var extSystem = (ExtendedActorSystem)system;
                 var logger = extSystem.SystemActorOf(Props.Create(() => new TestOutputLogger(Output)), "log-test");
-                logger.Tell(new InitializeLogger(system.EventStream));
+                logger.Ask<LoggerInitialized>(new InitializeLogger(system.EventStream), TimeSpan.FromSeconds(3))
+                    .ConfigureAwait(false).GetAwaiter().GetResult();
             }
         }
 
@@ -156,7 +157,8 @@ protected void InitializeLogger(ActorSystem system, string prefix)
                 var extSystem = (ExtendedActorSystem)system;
                 var logger = extSystem.SystemActorOf(Props.Create(() => new TestOutputLogger(
                     string.IsNullOrEmpty(prefix) ? Output : new PrefixedOutput(Output, prefix))), "log-test");
-                logger.Tell(new InitializeLogger(system.EventStream));
+                logger.Ask<LoggerInitialized>(new InitializeLogger(system.EventStream), TimeSpan.FromSeconds(3))
+                    .ConfigureAwait(false).GetAwaiter().GetResult();
             }
         }
         public virtual Task InitializeAsync()