diff --git a/Partner-Framework/src/main/java/work/slhaf/partner/api/agent/runtime/interaction/AgentGateway.java b/Partner-Framework/src/main/java/work/slhaf/partner/api/agent/runtime/interaction/AgentGateway.java index cfdbf660..5c38c219 100644 --- a/Partner-Framework/src/main/java/work/slhaf/partner/api/agent/runtime/interaction/AgentGateway.java +++ b/Partner-Framework/src/main/java/work/slhaf/partner/api/agent/runtime/interaction/AgentGateway.java @@ -9,9 +9,7 @@ public interface AgentGateway { - fun call(runningFlowContext: C): C = runBlocking { + fun submit(inputData: I): O { + val finalInputData: C = parseInputData(inputData) + val outputContext: C = call(finalInputData) + return parseOutputData(outputContext) + } + + private fun call(runningFlowContext: C): C = runBlocking { val runningModules = mutableMapOf>>>()