Merge pull request #1167 from kalenikalexander/handle_backpressure

sidorares · web-flow · commit 2be0eb6298bc · 2020-09-15T10:01:41.000+10:00
handle backpressure when loading data from file
diff --git a/lib/connection.js b/lib/connection.js
@@ -227,11 +227,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
`@@ -227,11 +227,15 @@ class Connection extends EventEmitter {`
`227`	`227`	`}`
`228`	`228`
`229`	`229`	`write(buffer) {`
`230`		`- this.stream.write(buffer, err => {`
	`230`	`+ const result = this.stream.write(buffer, err => {`
`231`	`231`	`if (err) {`
`232`	`232`	`this._handleNetworkError(err);`
`233`	`233`	`}`
`234`	`234`	`});`
	`235`	`+`
	`236`	`+ if (!result) {`
	`237`	`+ this.stream.emit('pause');`
	`238`	`+ }`
`235`	`239`	`}`
`236`	`240`
`237`	`241`	`// http://dev.mysql.com/doc/internals/en/sequence-id.html`