11use crate :: awakeable_holder;
22use restate_sdk:: prelude:: * ;
33
4- #[ restate_sdk:: service ]
4+ #[ restate_sdk:: object ]
55#[ name = "KillTestRunner" ]
66pub ( crate ) trait KillTestRunner {
77 #[ name = "startCallTree" ]
@@ -11,9 +11,9 @@ pub(crate) trait KillTestRunner {
1111pub ( crate ) struct KillTestRunnerImpl ;
1212
1313impl KillTestRunner for KillTestRunnerImpl {
14- async fn start_call_tree ( & self , context : Context < ' _ > ) -> HandlerResult < ( ) > {
14+ async fn start_call_tree ( & self , context : ObjectContext < ' _ > ) -> HandlerResult < ( ) > {
1515 context
16- . object_client :: < KillTestSingletonClient > ( "" )
16+ . object_client :: < KillTestSingletonClient > ( context . key ( ) )
1717 . recursive_call ( )
1818 . call ( )
1919 . await ?;
@@ -35,14 +35,14 @@ pub(crate) struct KillTestSingletonImpl;
3535impl KillTestSingleton for KillTestSingletonImpl {
3636 async fn recursive_call ( & self , context : ObjectContext < ' _ > ) -> HandlerResult < ( ) > {
3737 let awakeable_holder_client =
38- context. object_client :: < awakeable_holder:: AwakeableHolderClient > ( "kill" ) ;
38+ context. object_client :: < awakeable_holder:: AwakeableHolderClient > ( context . key ( ) ) ;
3939
4040 let ( awk_id, awakeable) = context. awakeable :: < ( ) > ( ) ;
4141 awakeable_holder_client. hold ( awk_id) . send ( ) ;
4242 awakeable. await ?;
4343
4444 context
45- . object_client :: < KillTestSingletonClient > ( "" )
45+ . object_client :: < KillTestSingletonClient > ( context . key ( ) )
4646 . recursive_call ( )
4747 . call ( )
4848 . await ?;
0 commit comments