Skip to content

Commit 4dfa889

Browse files
committed
close the stream on error
1 parent e3e5af3 commit 4dfa889

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

src/server/webStandardStreamableHttp.ts

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -501,6 +501,11 @@ export class WebStandardStreamableHTTPServerTransport implements Transport {
501501
const success = this.writeSSEEvent(streamController!, encoder, message, eventId);
502502
if (!success) {
503503
this.onerror?.(new Error('Failed replay events'));
504+
try {
505+
streamController!.close();
506+
} catch {
507+
// Controller might already be closed
508+
}
504509
}
505510
}
506511
});

0 commit comments

Comments
 (0)