diff --git a/crates/pi-natives/src/shell.rs b/crates/pi-natives/src/shell.rs index 8a662f0dfd..685d30da57 100644 --- a/crates/pi-natives/src/shell.rs +++ b/crates/pi-natives/src/shell.rs @@ -294,16 +294,6 @@ fn bridge_chunks( // marks dropped output at the N-API callback boundary instead of silently // losing it, so truncation is always observable to the caller. while let Some(chunk) = rx.recv().await { - if dropped_chunks > 0 { - match bounded_tx.try_send(shell_loss_marker(dropped_chunks, dropped_bytes)) { - Ok(()) => { - dropped_chunks = 0; - dropped_bytes = 0; - }, - Err(mpsc::error::TrySendError::Full(_)) => {}, - Err(mpsc::error::TrySendError::Closed(_)) => break, - } - } let chunk_len = chunk.len(); match bounded_tx.try_send(chunk) { Ok(()) => {}, diff --git a/packages/coding-agent/test/telegram-baseline-manifest.test.ts b/packages/coding-agent/test/telegram-baseline-manifest.test.ts index 4d0ab373e9..5310ed150c 100644 --- a/packages/coding-agent/test/telegram-baseline-manifest.test.ts +++ b/packages/coding-agent/test/telegram-baseline-manifest.test.ts @@ -333,7 +333,7 @@ describe("test manifest runner", () => { expect(result.exitCode, output(result)).toBe(0); expect(output(result)).toContain(`manifest command receipts complete: ${manifest.commands.length}`); expect(output(result)).toContain( - "manifest row receipts complete: 570 (telegram=95, discord=95, slack=95, mcp=95, acp=95, daemonCli=95)", + "manifest row receipts complete: 576 (telegram=96, discord=96, slack=96, mcp=96, acp=96, daemonCli=96)", ); const invocations = (await Bun.file(fake.log).text()).trim().split("\n"); expect(invocations).toHaveLength(manifest.commands.length + manifest.rows.length);