fix: stream forwarder silently drops events on send failure

When the stream receiver's buffer was full or the receiver was dropped,
the forwarder would set `forward_enabled = false` but continue consuming
events from `runtime_rx` without forwarding them. This caused the final
`End` event (containing the response text) to be silently discarded,
resulting in empty output from session.stream.

Fix: break out of the forwarder loop immediately when `tx.send()` fails
rather than continuing to consume events. Also add a warn log for
debugging.

Also bump version to 1.9.2 and fix a3s-code-node dependency on core
(was pointing to 1.9.0 instead of matching workspace version).

Author: claude

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "a3s-code-core"
-version = "1.9.1"
+version = "1.9.2"
 edition = "2021"
 authors = ["A3S Lab Team"]
 license = "MIT"

core/Cargo.toml

@@ -2056,11 +2056,13 @@ impl AgentSession {
         let agent_loop = self.build_agent_loop();
         let runtime_state = Arc::clone(&self.active_tools);
         let forwarder = tokio::spawn(async move {
-            let mut forward_enabled = true;
             while let Some(event) = runtime_rx.recv().await {
                 AgentSession::apply_runtime_event(&runtime_state, &event).await;
-                if forward_enabled && tx.send(event).await.is_err() {
-                    forward_enabled = false;
+                if tx.send(event).await.is_err() {
+                    // Receiver dropped or buffer full — stop forwarding to avoid
+                    // silently dropping subsequent events (e.g., the final `End`).
+                    tracing::warn!("stream forwarder: receiver dropped, stopping event forward");
+                    break;
                 }
             }
         });
@@ -2177,11 +2179,13 @@ impl AgentSession {
         let token_clone = cancel_token.clone();
         let runtime_state = Arc::clone(&self.active_tools);
         let forwarder = tokio::spawn(async move {
-            let mut forward_enabled = true;
             while let Some(event) = runtime_rx.recv().await {
                 AgentSession::apply_runtime_event(&runtime_state, &event).await;
-                if forward_enabled && tx.send(event).await.is_err() {
-                    forward_enabled = false;
+                if tx.send(event).await.is_err() {
+                    // Receiver dropped or buffer full — stop forwarding to avoid
+                    // silently dropping subsequent events (e.g., the final `End`).
+                    tracing::warn!("stream forwarder: receiver dropped, stopping event forward");
+                    break;
                 }
             }
         });

core/src/agent_api.rs

@@ -1,6 +1,6 @@
 [package]
 name = "a3s-code-node"
-version = "1.9.1"
+version = "1.9.2"
 edition = "2021"
 authors = ["A3S Lab Team"]
 license = "MIT"
@@ -11,7 +11,7 @@ description = "A3S Code Node.js bindings - Native addon via napi-rs"
 crate-type = ["cdylib"]
 
 [dependencies]
-a3s-code-core = { version = "1.9.0", path = "../../core", features = ["ahp"] }
+a3s-code-core = { version = "1.9.2", path = "../../core", features = ["ahp"] }
 napi = { version = "2", features = ["async", "napi6", "serde-json"] }
 napi-derive = "2"
 tokio = { version = "1.35", features = ["full"] }

sdk/node/Cargo.toml

@@ -1,7 +1,7 @@
 #!/usr/bin/env npx tsx
 /**
- * Stream fix verification test.
- * Uses kimi model from config and logs ALL event types to verify no "unknown" appears.
+ * Stream fix verification test - matches user's issue code exactly.
+ * Uses kimi model and maxToolRounds: 0 (no tool calls) as reported.
  */
 
 import { Agent, Session } from '../../index.js';
@@ -12,12 +12,16 @@ async function main(): Promise<void> {
   const configPath = process.env.A3S_CONFIG || path.join(os.homedir(), '.a3s', 'config.hcl');
   console.log(`Using config: ${configPath}\n`);
   console.log('='.repeat(80));
-  console.log('Stream Fix Verification Test');
+  console.log('Stream Fix Verification Test (maxToolRounds: 0, no tools)');
   console.log('='.repeat(80));
   console.log();
 
   const agent = await Agent.create(configPath);
-  const session = agent.session('.');
+  // User's exact code: maxToolRounds: 0 to disable tool calls
+  const session = agent.session('.', {
+    permissive: true,
+    max_tool_rounds: 0,
+  });
 
   console.log('Streaming with prompt: "Say hello in 5 words"\n');
 

sdk/node/examples/streaming/stream_fix_test.ts

@@ -1,6 +1,6 @@
 {
   "name": "@a3s-lab/code",
-  "version": "1.9.1",
+  "version": "1.9.2",
   "description": "A3S Code - Native AI coding agent library for Node.js",
   "main": "index.js",
   "types": "index.d.ts",
@@ -44,11 +44,11 @@
     "test:loop": "tsx --tsconfig examples/tsconfig.json examples/test_loop_commands.ts"
   },
   "optionalDependencies": {
-    "@a3s-lab/code-darwin-arm64": "1.9.1",
-    "@a3s-lab/code-linux-x64-gnu": "1.9.1",
-    "@a3s-lab/code-linux-x64-musl": "1.9.1",
-    "@a3s-lab/code-linux-arm64-gnu": "1.9.1",
-    "@a3s-lab/code-linux-arm64-musl": "1.9.1",
-    "@a3s-lab/code-win32-x64-msvc": "1.9.1"
+    "@a3s-lab/code-darwin-arm64": "1.9.2",
+    "@a3s-lab/code-linux-x64-gnu": "1.9.2",
+    "@a3s-lab/code-linux-x64-musl": "1.9.2",
+    "@a3s-lab/code-linux-arm64-gnu": "1.9.2",
+    "@a3s-lab/code-linux-arm64-musl": "1.9.2",
+    "@a3s-lab/code-win32-x64-msvc": "1.9.2"
   }
 }

sdk/node/package-lock.json

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "a3s-code"
-version = "1.9.1"
+version = "1.9.2"
 description = "A3S Code Python bootstrap package that fetches platform-native binaries from GitHub Releases"
 readme = "../python/README.md"
 license = { text = "MIT" }

sdk/node/package.json

@@ -1,6 +1,6 @@
 [package]
 name = "a3s-code-py"
-version = "1.9.1"
+version = "1.9.2"
 edition = "2021"
 authors = ["A3S Lab Team"]
 license = "MIT"
@@ -12,7 +12,7 @@ name = "a3s_code"
 crate-type = ["cdylib"]
 
 [dependencies]
-a3s-code-core = { version = "1.9.1", path = "../../core", features = ["ahp"] }
+a3s-code-core = { version = "1.9.2", path = "../../core", features = ["ahp"] }
 pyo3 = "0.23"
 tokio = { version = "1.35", features = ["full"] }
 serde_json = "1.0"

sdk/python-bootstrap/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "maturin"
 
 [project]
 name = "a3s-code"
-version = "1.9.1"
+version = "1.9.2"
 description = "A3S Code - Native Python bindings for the AI coding agent"
 readme = "README.md"
 license = {text = "MIT"}