1
1
use crate :: awakeable_holder;
2
2
use restate_sdk:: prelude:: * ;
3
3
4
- #[ restate_sdk:: service ]
4
+ #[ restate_sdk:: object ]
5
5
#[ name = "KillTestRunner" ]
6
6
pub ( crate ) trait KillTestRunner {
7
7
#[ name = "startCallTree" ]
@@ -11,9 +11,9 @@ pub(crate) trait KillTestRunner {
11
11
pub ( crate ) struct KillTestRunnerImpl ;
12
12
13
13
impl KillTestRunner for KillTestRunnerImpl {
14
- async fn start_call_tree ( & self , context : Context < ' _ > ) -> HandlerResult < ( ) > {
14
+ async fn start_call_tree ( & self , context : ObjectContext < ' _ > ) -> HandlerResult < ( ) > {
15
15
context
16
- . object_client :: < KillTestSingletonClient > ( "" )
16
+ . object_client :: < KillTestSingletonClient > ( context . key ( ) )
17
17
. recursive_call ( )
18
18
. call ( )
19
19
. await ?;
@@ -35,14 +35,14 @@ pub(crate) struct KillTestSingletonImpl;
35
35
impl KillTestSingleton for KillTestSingletonImpl {
36
36
async fn recursive_call ( & self , context : ObjectContext < ' _ > ) -> HandlerResult < ( ) > {
37
37
let awakeable_holder_client =
38
- context. object_client :: < awakeable_holder:: AwakeableHolderClient > ( "kill" ) ;
38
+ context. object_client :: < awakeable_holder:: AwakeableHolderClient > ( context . key ( ) ) ;
39
39
40
40
let ( awk_id, awakeable) = context. awakeable :: < ( ) > ( ) ;
41
41
awakeable_holder_client. hold ( awk_id) . send ( ) ;
42
42
awakeable. await ?;
43
43
44
44
context
45
- . object_client :: < KillTestSingletonClient > ( "" )
45
+ . object_client :: < KillTestSingletonClient > ( context . key ( ) )
46
46
. recursive_call ( )
47
47
. call ( )
48
48
. await ?;
0 commit comments