Skip to content

Commit 12932b2

Browse files
Fix interpreter send
1 parent 87b1ee0 commit 12932b2

File tree

1 file changed

+14
-12
lines changed
  • test-services/src/main/kotlin/dev/restate/sdk/testservices

1 file changed

+14
-12
lines changed

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

Lines changed: 14 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -212,12 +212,13 @@ class ServiceInterpreterHelperImpl : ServiceInterpreterHelper {
212212
}
213213

214214
override suspend fun incrementIndirectly(ctx: Context, id: InterpreterId) {
215-
ctx.send(
216-
SendRequest.of(
217-
interpretTarget(id.layer, id.key),
218-
ObjectInterpreterMetadata.Serde.INTERPRET_INPUT,
219-
Serde.SLICE,
220-
Program(listOf(IncrementStateCounter()))))
215+
val ignored =
216+
ctx.send(
217+
SendRequest.of(
218+
interpretTarget(id.layer, id.key),
219+
ObjectInterpreterMetadata.Serde.INTERPRET_INPUT,
220+
Serde.SLICE,
221+
Program(listOf(IncrementStateCounter()))))
221222
}
222223

223224
override suspend fun resolveAwakeable(ctx: Context, id: String) {
@@ -247,11 +248,12 @@ class ServiceInterpreterHelperImpl : ServiceInterpreterHelper {
247248
//
248249
// 4. to thank our interpret, let us ask it to inc its state.
249250
//
250-
ctx.send(
251-
SendRequest.of(
252-
interpretTarget(req.interpreter.layer, req.interpreter.key),
253-
ObjectInterpreterMetadata.Serde.INTERPRET_INPUT,
254-
Serde.SLICE,
255-
Program(listOf(IncrementStateCounter()))))
251+
val ignored =
252+
ctx.send(
253+
SendRequest.of(
254+
interpretTarget(req.interpreter.layer, req.interpreter.key),
255+
ObjectInterpreterMetadata.Serde.INTERPRET_INPUT,
256+
Serde.SLICE,
257+
Program(listOf(IncrementStateCounter()))))
256258
}
257259
}

0 commit comments

Comments
 (0)