build

porsager · Apr 9, 2024 · 18d750b · 18d750b
1 parent 9ab8f85
commit 18d750b
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/cf/src/connection.js b/cf/src/connection.js
@@ -958,14 +958,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
  ])
  }
 

diff --git a/cjs/src/connection.js b/cjs/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
  ])
  }
 

diff --git a/deno/src/connection.js b/deno/src/connection.js
@@ -959,14 +959,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
  ])
  }