Skip to content

Commit 9ab8f85

Browse files
committed
Only necessary to do flush during cursor - closes #736
1 parent cc688c6 commit 9ab8f85

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/connection.js

+2-2
Original file line numberDiff line numberDiff line change
@@ -956,14 +956,14 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
956956
function Execute(portal = '', rows = 0) {
957957
return Buffer.concat([
958958
b().E().str(portal + b.N).i32(rows).end(),
959-
Flush
959+
rows === 0 ? Sync : Flush
960960
])
961961
}
962962

963963
function Close(portal = '') {
964964
return Buffer.concat([
965965
b().C().str('P').str(portal + b.N).end(),
966-
b().S().end()
966+
Sync
967967
])
968968
}
969969

0 commit comments

Comments
 (0)