slhaf/Partner
1
0
Fork 0
mirror of https://github.com/slhaf/Partner.git synced 2026-05-12 16:53:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(framework): mv interaction in-out flow into AgentInteractionAdapter

Browse Source
This commit is contained in:
slhafzjw
2026-03-03 11:48:08 +08:00
parent 5ae8b713d7
commit d462f02960
2 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
Partner-Framework/src/main/java/work/slhaf/partner/api/agent/runtime/interaction/AgentGateway.java
View File

@@ -9,9 +9,7 @@ public interface AgentGateway<I extends AgentInputData, O extends AgentOutputDat
void launch(); void launch();
default void receive(I inputData) { default void receive(I inputData) {
C finalInputData = adapter().parseInputData(inputData); O outputData = adapter().submit(inputData);
C outputContext = adapter().call(finalInputData);
O outputData = adapter().parseOutputData(outputContext);
send(outputData); send(outputData);
} }

8
Partner-Framework/src/main/java/work/slhaf/partner/api/agent/runtime/interaction/AgentInteractionAdapter.kt
View File

@@ -13,7 +13,13 @@ import work.slhaf.partner.api.agent.runtime.interaction.flow.RunningFlowContext
abstract class AgentInteractionAdapter<I : AgentInputData, O : AgentOutputData, C : RunningFlowContext> { abstract class AgentInteractionAdapter<I : AgentInputData, O : AgentOutputData, C : RunningFlowContext> {
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 = val runningModules =
mutableMapOf<Int, MutableList<ModuleContextData.Running<AbstractAgentModule.Running<RunningFlowContext>>>>() mutableMapOf<Int, MutableList<ModuleContextData.Running<AbstractAgentModule.Running<RunningFlowContext>>>>()