diff --git a/packages/agent/src/proxy.ts b/packages/agent/src/proxy.ts index b1f71ba84..92d2a5553 100644 --- a/packages/agent/src/proxy.ts +++ b/packages/agent/src/proxy.ts @@ -167,9 +167,8 @@ export function streamProxy(model: Model, context: Context, options: ProxyStream } } - if (options.signal?.aborted && !sawTerminalEvent) { - const reason = options.signal.reason; - throw reason instanceof Error ? reason : new Error(String(reason ?? "Request aborted")); + if (!sawTerminalEvent) { + throw new Error("Proxy stream ended without a terminal event (done or error)"); } stream.end();