diff --git a/packages/ai/src/route/executor.ts b/packages/ai/src/route/executor.ts index 6786b9f2a22..b9628954863 100644 --- a/packages/ai/src/route/executor.ts +++ b/packages/ai/src/route/executor.ts @@ -372,9 +372,7 @@ export const stream = ( const redactedNames = yield* Headers.CurrentRedactedNames const response = yield* executor.execute(request, middleware) return response.stream.pipe( - Stream.mapError((error) => - httpError({ error, request: response.request, operation: "read", redactedNames }), - ), + Stream.mapError((error) => httpError({ error, request: response.request, operation: "read", redactedNames })), ) }), ) diff --git a/packages/ai/test/executor.test.ts b/packages/ai/test/executor.test.ts index 7a483bbbd4d..25750d174f4 100644 --- a/packages/ai/test/executor.test.ts +++ b/packages/ai/test/executor.test.ts @@ -114,9 +114,7 @@ describe("RequestExecutor", () => { new Response( new ReadableStream({ pull(controller) { - controller.error( - new TypeError("fetch failed", { cause: systemError("ECONNRESET", "socket closed") }), - ) + controller.error(new TypeError("fetch failed", { cause: systemError("ECONNRESET", "socket closed") })) }, }), ),