fix: Ensure socket is unpaused after COPY stream is complete

valeneiko · valeneiko · commit ea1737f0101d · 2025-01-21T19:11:55.000Z
diff --git a/src/connection.js b/src/connection.js
@@ -884,6 +884,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
   function CopyDone() {
     stream && stream.push(null)
     stream = null
+    socket.isPaused() && socket.resume()
   }
 
   function NoticeResponse(x) {

Original file line number	Diff line number	Diff line change
`@@ -884,6 +884,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose`
`884`	`884`	`function CopyDone() {`
`885`	`885`	`stream && stream.push(null)`
`886`	`886`	`stream = null`
	`887`	`+ socket.isPaused() && socket.resume()`
`887`	`888`	`}`
`888`	`889`
`889`	`890`	`function NoticeResponse(x) {`