From 6877e96459abee2f7e9ecdf2bca28a48374c3cf9 Mon Sep 17 00:00:00 2001 From: Giselle van Dongen Date: Thu, 13 Jun 2024 10:38:56 +0200 Subject: [PATCH] Cleanup --- .../main/kotlin/develop/signals/MyWorkflow.kt | 41 ------------------- 1 file changed, 41 deletions(-) delete mode 100644 code_snippets/kotlin/src/main/kotlin/develop/signals/MyWorkflow.kt diff --git a/code_snippets/kotlin/src/main/kotlin/develop/signals/MyWorkflow.kt b/code_snippets/kotlin/src/main/kotlin/develop/signals/MyWorkflow.kt deleted file mode 100644 index aefa260d..00000000 --- a/code_snippets/kotlin/src/main/kotlin/develop/signals/MyWorkflow.kt +++ /dev/null @@ -1,41 +0,0 @@ -package develop.signals - -import dev.restate.sdk.annotation.Handler -import dev.restate.sdk.annotation.Workflow -import dev.restate.sdk.kotlin.KtDurablePromiseKey -import dev.restate.sdk.kotlin.SharedWorkflowContext -import dev.restate.sdk.kotlin.WorkflowContext - -// -@Workflow -class MyWorkflow { - - companion object { - private val MY_BOOLEAN_SIGNAL = KtDurablePromiseKey.json("my-boolean-signal") - } - - @Workflow - suspend fun run(ctx: WorkflowContext, input: String): String { - - // do some steps... - - // withClass highlight-line - // Creation of the Durable Promise - // withClass highlight-line - val signal: Boolean = ctx.promise(MY_BOOLEAN_SIGNAL).awaitable().await() - - // do some steps... - - return "success" - } - - @Handler - suspend fun resolveMySignal(ctx: SharedWorkflowContext, signal: Boolean) { - // withClass highlight-line - // Resolution of the Durable Promise - // withClass highlight-line - ctx.promiseHandle(MY_BOOLEAN_SIGNAL).resolve(signal) - } - -} -//