Only necessary to do flush during cursor - closes #736

porsager · Apr 9, 2024 · 9ab8f85 · 9ab8f85
1 parent cc688c6
commit 9ab8f85
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/connection.js b/src/connection.js
@@ -956,14 +956,14 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
  function Execute(portal = '', rows = 0) {
  return Buffer.concat([
  b().E().str(portal + b.N).i32(rows).end(),
- Flush
+ rows === 0 ? Sync : Flush
  ])
  }
 
  function Close(portal = '') {
  return Buffer.concat([
  b().C().str('P').str(portal + b.N).end(),
- b().S().end()
+ Sync
  ])
  }