Skip to content

Commit e4b8c5f

Browse files
committed
fix(use/express): make sure that we not send something through previously closed stream
1 parent 0d2c135 commit e4b8c5f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/use/express.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ export function createHandler<Context extends OperationContext = undefined>(
9696
res.once('close', body.return);
9797
for await (const value of body) {
9898
const closed = await new Promise((resolve, reject) => {
99-
if (!res.writable) {
99+
if (!res.writable || res.destroyed) {
100100
// response's close event might be late
101101
resolve(true);
102102
} else {

0 commit comments

Comments
 (0)