Set noDelay to true

brianc · brianc · commit 08afb12dccac · 2020-05-12T16:32:40.000-05:00
diff --git a/packages/pg/lib/connection.js b/packages/pg/lib/connection.js
@@ -39,6 +39,7 @@ Connection.prototype.connect = function (port, host) {
   var self = this
 
   this._connecting = true
+  this.stream.setNoDelay(true)
   this.stream.connect(port, host)
 
   this.stream.once('connect', function () {
diff --git a/packages/pg/test/unit/client/stream-and-query-error-interaction-tests.js b/packages/pg/test/unit/client/stream-and-query-error-interaction-tests.js
@@ -5,6 +5,7 @@ var Client = require(__dirname + '/../../../lib/client')
 
 test('emits end when not in query', function () {
   var stream = new (require('events').EventEmitter)()
+  stream.setNoDelay = () => {}
   stream.connect = function () {
     // NOOP
   }
diff --git a/packages/pg/test/unit/test-helper.js b/packages/pg/test/unit/test-helper.js
@@ -17,6 +17,8 @@ p.connect = function () {
   // NOOP
 }
 
+p.setNoDelay = () => {}
+
 p.write = function (packet, cb) {
   this.packets.push(packet)
   if (cb) {

Original file line number	Diff line number	Diff line change
`@@ -5,6 +5,7 @@ var Client = require(__dirname + '/../../../lib/client')`
`5`	`5`
`6`	`6`	`test('emits end when not in query', function () {`
`7`	`7`	`var stream = new (require('events').EventEmitter)()`
	`8`	`+ stream.setNoDelay = () => {}`
`8`	`9`	`stream.connect = function () {`
`9`	`10`	`// NOOP`
`10`	`11`	`}`