Create run by request in AssistantThread (#678)

xebia-functional · Mar 11, 2024 · 7789b3d · 7789b3d
1 parent a7a0b9e
commit 7789b3d
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/core/src/commonMain/kotlin/com/xebia/functional/xef/llm/assistants/AssistantThread.kt b/core/src/commonMain/kotlin/com/xebia/functional/xef/llm/assistants/AssistantThread.kt
@@ -63,6 +63,11 @@ class AssistantThread(
     return awaitRun(assistant, run.id)
   }
 
+  suspend fun run(assistant: Assistant, request: CreateRunRequest): Flow<RunDelta> {
+    val run = createRun(request)
+    return awaitRun(assistant, run.id)
+  }
+
   suspend fun cancelRun(runId: String): RunObject = api.cancelRun(threadId, runId).body()
 
   suspend fun runSteps(runId: String): List<RunStepObject> =