diff --git a/src/connection.js b/src/connection.js index 97cc97e1..d98dded1 100644 --- 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) {