Skip to content

Commit a20c73d

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

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

index.js

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,11 @@ function isFinished (msg) {
6767

6868
if (typeof msg.finished === 'boolean') {
6969
// OutgoingMessage
70-
return Boolean(msg.finished || (socket && !socket.writable))
70+
return Boolean(
71+
(!socket && msg.finished && msg.outputSize === 0) ||
72+
(socket && !socket.writable) ||
73+
(msg.stream && msg.stream.closed)
74+
)
7175
}
7276

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

0 commit comments

Comments
 (0)