From 6b624af4d0d6e905ef2b52e8c153389c04016c63 Mon Sep 17 00:00:00 2001 From: decolua Date: Sat, 14 Mar 2026 11:38:33 +0700 Subject: [PATCH] fix: Update abort method in pipeWithDisconnect to return a promise for better error handling --- open-sse/utils/streamHandler.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/open-sse/utils/streamHandler.js b/open-sse/utils/streamHandler.js index 27580641..10ac6535 100644 --- a/open-sse/utils/streamHandler.js +++ b/open-sse/utils/streamHandler.js @@ -131,7 +131,7 @@ export function createDisconnectAwareStream(transformStream, streamController) { export function pipeWithDisconnect(providerResponse, transformStream, streamController) { const transformedBody = providerResponse.body.pipeThrough(transformStream); return createDisconnectAwareStream( - { readable: transformedBody, writable: { getWriter: () => ({ abort: () => {} }) } }, + { readable: transformedBody, writable: { getWriter: () => ({ abort: () => Promise.resolve() }) } }, streamController ); }