Skip to content

Commit faf88d8

Browse files
authored
Merge pull request #1306 from horochx/patch-4
fix: handle stream close failures
2 parents 69b97a8 + 7549920 commit faf88d8

File tree

1 file changed

+12
-4
lines changed

1 file changed

+12
-4
lines changed

src/handlers/streamHandler.ts

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -321,9 +321,13 @@ export function handleStreamingMode(
321321
await writer.write(encoder.encode(chunk));
322322
}
323323
} catch (error) {
324-
console.error(error);
324+
console.error('Error during stream processing:', error);
325325
} finally {
326-
writer.close();
326+
try {
327+
await writer.close();
328+
} catch (closeError) {
329+
console.error('Failed to close the writer:', closeError);
330+
}
327331
}
328332
})();
329333
} else {
@@ -341,9 +345,13 @@ export function handleStreamingMode(
341345
await writer.write(encoder.encode(chunk));
342346
}
343347
} catch (error) {
344-
console.error(error);
348+
console.error('Error during stream processing:', error);
345349
} finally {
346-
writer.close();
350+
try {
351+
await writer.close();
352+
} catch (closeError) {
353+
console.error('Failed to close the writer:', closeError);
354+
}
347355
}
348356
})();
349357
}

0 commit comments

Comments
 (0)