Skip to content

Commit 391ef13

Browse files
Update KillTest (#463)
1 parent 64a5d4e commit 391ef13

File tree

2 files changed

+6
-8
lines changed

2 files changed

+6
-8
lines changed

test-services/src/main/kotlin/dev/restate/sdk/testservices/KillTestImpl.kt

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@
88
// https://github.com/restatedev/sdk-java/blob/main/LICENSE
99
package dev.restate.sdk.testservices
1010

11-
import dev.restate.sdk.kotlin.Context
1211
import dev.restate.sdk.kotlin.ObjectContext
1312
import dev.restate.sdk.testservices.contracts.AwakeableHolderClient
1413
import dev.restate.sdk.testservices.contracts.KillTest
@@ -22,19 +21,19 @@ class KillTestImpl {
2221
// This will ensure that we have a call tree that is two calls deep and has a pending invocation
2322
// in the inbox:
2423
// startCallTree --> recursiveCall --> recursiveCall:inboxed
25-
override suspend fun startCallTree(context: Context) {
26-
KillTestSingletonClient.fromContext(context, "").recursiveCall().await()
24+
override suspend fun startCallTree(context: ObjectContext) {
25+
KillTestSingletonClient.fromContext(context, context.key()).recursiveCall().await()
2726
}
2827
}
2928

3029
class SingletonImpl : KillTest.Singleton {
3130
override suspend fun recursiveCall(context: ObjectContext) {
3231
val awakeable = context.awakeable(Serde.RAW)
33-
AwakeableHolderClient.fromContext(context, "kill").send().hold(awakeable.id)
32+
AwakeableHolderClient.fromContext(context, context.key()).send().hold(awakeable.id)
3433

3534
awakeable.await()
3635

37-
KillTestSingletonClient.fromContext(context, "").recursiveCall().await()
36+
KillTestSingletonClient.fromContext(context, context.key()).recursiveCall().await()
3837
}
3938

4039
override suspend fun isUnlocked(context: ObjectContext) {

test-services/src/main/kotlin/dev/restate/sdk/testservices/contracts/KillTest.kt

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,13 +9,12 @@
99
package dev.restate.sdk.testservices.contracts
1010

1111
import dev.restate.sdk.annotation.*
12-
import dev.restate.sdk.kotlin.Context
1312
import dev.restate.sdk.kotlin.ObjectContext
1413

1514
interface KillTest {
16-
@Service(name = "KillTestRunner")
15+
@VirtualObject(name = "KillTestRunner")
1716
interface Runner {
18-
@Handler suspend fun startCallTree(context: Context)
17+
@Handler suspend fun startCallTree(context: ObjectContext)
1918
}
2019

2120
@VirtualObject(name = "KillTestSingleton")

0 commit comments

Comments
 (0)