Skip to content

Commit ec12f71

Browse files
committed
msg.finished is only finished if socket has been detached
1 parent 08345db commit ec12f71

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

index.js

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,10 +64,17 @@ function onFinished (msg, listener) {
6464

6565
function isFinished (msg) {
6666
var socket = msg.socket
67+
var stream = msg.stream
68+
69+
if (stream && typeof stream.closed === 'boolean') {
70+
// Http2ServerRequest
71+
// Http2ServerResponse
72+
return stream.closed
73+
}
6774

6875
if (typeof msg.finished === 'boolean') {
6976
// OutgoingMessage
70-
return Boolean(msg.finished || (socket && !socket.writable))
77+
return Boolean((!socket && msg.finished && msg.outputSize === 0) || (socket && !socket.writable))
7178
}
7279

7380
if (typeof msg.complete === 'boolean') {

0 commit comments

Comments
 (0)