handle backpressure when loading data from file

kalenikalexander · rnavarych · commit dbaed31460f0 · 2020-06-18T17:56:27.000+03:00
diff --git a/lib/connection.js b/lib/connection.js
@@ -223,11 +223,15 @@ class Connection extends EventEmitter {
   }
 
   write(buffer) {
-    this.stream.write(buffer, err => {
+    const result = this.stream.write(buffer, err => {
       if (err) {
         this._handleNetworkError(err);
       }
     });
+
+    if (!result) {
+      this.stream.emit('pause');
+    }
   }
 
   // http://dev.mysql.com/doc/internals/en/sequence-id.html

Original file line number	Diff line number	Diff line change
`@@ -223,11 +223,15 @@ class Connection extends EventEmitter {`
`223`	`223`	`}`
`224`	`224`
`225`	`225`	`write(buffer) {`
`226`		`- this.stream.write(buffer, err => {`
	`226`	`+ const result = this.stream.write(buffer, err => {`
`227`	`227`	`if (err) {`
`228`	`228`	`this._handleNetworkError(err);`
`229`	`229`	`}`
`230`	`230`	`});`
	`231`	`+`
	`232`	`+ if (!result) {`
	`233`	`+ this.stream.emit('pause');`
	`234`	`+ }`
`231`	`235`	`}`
`232`	`236`
`233`	`237`	`// http://dev.mysql.com/doc/internals/en/sequence-id.html`