File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
src/core/Akka.Cluster.Tests/Routing Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change 6
6
//-----------------------------------------------------------------------
7
7
8
8
using System ;
9
+ using System . Threading . Tasks ;
9
10
using Akka . Actor ;
10
11
using Akka . Cluster . Routing ;
11
12
using Akka . Dispatch ;
@@ -39,7 +40,7 @@ public KillableActor(IActorRef testActor)
39
40
}
40
41
41
42
[ Fact ]
42
- public void Cluster_aware_routers_must_use_provided_supervisor_strategy ( )
43
+ public async Task Cluster_aware_routers_must_use_provided_supervisor_strategy ( )
43
44
{
44
45
var escalator = new OneForOneStrategy (
45
46
exception =>
@@ -57,7 +58,7 @@ public void Cluster_aware_routers_must_use_provided_supervisor_strategy()
57
58
. Props ( Props . Create ( ( ) => new KillableActor ( TestActor ) ) ) , "therouter" ) ;
58
59
59
60
router . Tell ( "go away" ) ;
60
- ExpectMsg ( "supervised" ) ;
61
+ await ExpectMsgAsync ( "supervised" ) ;
61
62
}
62
63
}
63
64
}
You can’t perform that action at this time.
0 commit comments