patch

Author: tripolskypetr

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "agent-swarm-kit",
-  "version": "1.1.145",
+  "version": "1.1.146",
   "description": "A TypeScript library for building orchestrated framework-agnostic multi-agent AI systems",
   "author": {
     "name": "Petr Tripolsky",

package.json

@@ -62,7 +62,7 @@ const executeInternal = beginContext(
           let result = "";
           let errorValue = null;
 
-          const unError = errorSubject.once(([errorClientId, error]) => {
+          const unError = errorSubject.subscribe(([errorClientId, error]) => {
             if (clientId === errorClientId) {
               errorValue = error;
             }

src/functions/target/execute.ts

@@ -37,7 +37,7 @@ const executeForceInternal = beginContext(
           let result = "";
           let errorValue = null;
 
-          const unError = errorSubject.once(([errorClientId, error]) => {
+          const unError = errorSubject.subscribe(([errorClientId, error]) => {
             if (clientId === errorClientId) {
               errorValue = error;
             }

src/functions/target/executeForce.ts

@@ -152,7 +152,7 @@ const jsonInternal = beginContext(
         let output: IModelMessage | IOutlineMessage;
         let errorValue = null;
 
-        const unError = errorSubject.once(([errorClientId, error]) => {
+        const unError = errorSubject.subscribe(([errorClientId, error]) => {
           if (clientId === errorClientId) {
             errorValue = error;
           }

src/functions/target/json.ts

@@ -62,7 +62,7 @@ const runStatelessInternal = beginContext(
           let result = "";
           let errorValue = null;
 
-          const unError = errorSubject.once(([errorClientId, error]) => {
+          const unError = errorSubject.subscribe(([errorClientId, error]) => {
             if (clientId === errorClientId) {
               errorValue = error;
             }

src/functions/target/runStateless.ts

@@ -37,7 +37,7 @@ const runStatelessForceInternal = beginContext(
           let result = "";
           let errorValue = null;
 
-          const unError = errorSubject.once(([errorClientId, error]) => {
+          const unError = errorSubject.subscribe(([errorClientId, error]) => {
             if (clientId === errorClientId) {
               errorValue = error;
             }