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
   );
 }