Skip to content

Commit 6e615ae

Browse files
committed
Revert "Mark connection as closed immediately on terminate"
This reverts commit fc1fac5.
1 parent 2549e55 commit 6e615ae

File tree

3 files changed

+0
-3
lines changed

3 files changed

+0
-3
lines changed

cjs/src/connection.js

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -400,7 +400,6 @@ function Connection(options, { onopen = noop, onend = noop, ondrain = noop, oncl
400400
if (stream || query || initial || sent.length)
401401
error(Errors.connection('CONNECTION_DESTROYED', options))
402402

403-
onclose(connection)
404403
clearImmediate(nextWriteTimer)
405404
socket.removeListener('data', data)
406405
socket.removeListener('connect', connected)

deno/src/connection.js

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -403,7 +403,6 @@ function Connection(options, { onopen = noop, onend = noop, ondrain = noop, oncl
403403
if (stream || query || initial || sent.length)
404404
error(Errors.connection('CONNECTION_DESTROYED', options))
405405

406-
onclose(connection)
407406
clearImmediate(nextWriteTimer)
408407
socket.removeListener('data', data)
409408
socket.removeListener('connect', connected)

src/connection.js

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -400,7 +400,6 @@ function Connection(options, { onopen = noop, onend = noop, ondrain = noop, oncl
400400
if (stream || query || initial || sent.length)
401401
error(Errors.connection('CONNECTION_DESTROYED', options))
402402

403-
onclose(connection)
404403
clearImmediate(nextWriteTimer)
405404
socket.removeListener('data', data)
406405
socket.removeListener('connect', connected)

0 commit comments

Comments
 (0)