diff --git a/src/core/Akka.Tests/Dispatch/DispatchersSpec.cs b/src/core/Akka.Tests/Dispatch/DispatchersSpec.cs index b654f521644..73508a94f28 100644 --- a/src/core/Akka.Tests/Dispatch/DispatchersSpec.cs +++ b/src/core/Akka.Tests/Dispatch/DispatchersSpec.cs @@ -131,32 +131,43 @@ public void Dispatchers_must_be_used_when_configured_in_explicit_deployments() public void Dispatchers_must_be_used_in_deployment_configuration() { var actor = Sys.ActorOf(Props.Create(), "echo1"); - actor.Tell("what's in a name?"); - var expected = "myapp.mydispatcher"; - var actual = ExpectMsg(TimeSpan.FromMilliseconds(50)); - actual.ShouldBe(expected); + + AwaitAssert(() => + { + actor.Tell("what's in a name?"); + var expected = "myapp.mydispatcher"; + var actual = ExpectMsg(TimeSpan.FromMilliseconds(50)); + actual.ShouldBe(expected); + }); } [Fact] public void Dispatchers_must_be_used_in_deployment_configuration_and_trumps_code() { var actor = Sys.ActorOf(Props.Create().WithDispatcher("my-pinned-dispatcher"), "echo2"); - actor.Tell("what's in a name?"); - var expected = "myapp.my-fork-join-dispatcher"; - var actual = ExpectMsg(TimeSpan.FromMilliseconds(200)); - actual.ShouldBe(expected); + + AwaitAssert(() => + { + actor.Tell("what's in a name?"); + var expected = "myapp.my-fork-join-dispatcher"; + var actual = ExpectMsg(TimeSpan.FromMilliseconds(200)); + actual.ShouldBe(expected); + }); } [Fact] public void Dispatchers_must_use_pool_dispatcher_router_of_deployment_config() { var pool = Sys.ActorOf(Props.Create().WithRouter(FromConfig.Instance), "pool1"); - pool.Tell(new Identify(null)); - var routee = ExpectMsg().Subject; - routee.Tell("what's the name?"); - var expected = "akka.actor.deployment./pool1.pool-dispatcher"; - var actual = ExpectMsg(TimeSpan.FromMilliseconds(50)); - actual.ShouldBe(expected); + + AwaitAssert(() => { + pool.Tell(new Identify(null)); + var routee = ExpectMsg().Subject; + routee.Tell("what's the name?"); + var expected = "akka.actor.deployment./pool1.pool-dispatcher"; + var actual = ExpectMsg(TimeSpan.FromMilliseconds(50)); + actual.ShouldBe(expected); + }); } [Fact]