cartodb4/node-pg-copy-streams
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Small refactor

Browse Source
This commit is contained in:
Rafa de la Torre
2018-06-11 12:14:28 +02:00
parent 61bc713e0c
commit 922627daaf
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
copy-to.js
+10 -10
View File
@@ -46,6 +46,14 @@ CopyStreamQuery.prototype._transform = function(chunk, enc, cb) {
var buffer_offset = 0; var buffer_offset = 0;
var buffer_sent = false; var buffer_sent = false;
this.pushBufferIfneeded = function() {
if(needPush && !buffer_sent && buffer_offset > 0) {
this.push(buffer.slice(0, buffer_offset))
buffer_sent = true;
buffer_offset = 0;
}
}
while((chunk.length - offset) >= (Byte1Len + Int32Len)) { while((chunk.length - offset) >= (Byte1Len + Int32Len)) {
var messageCode = chunk[offset] var messageCode = chunk[offset]
@@ -74,11 +82,7 @@ CopyStreamQuery.prototype._transform = function(chunk, enc, cb) {
case code.ErrorResponse: case code.ErrorResponse:
case code.CopyDone: case code.CopyDone:
if(needPush && !buffer_sent && buffer_offset > 0) { this.pushBufferIfneeded();
this.push(buffer.slice(0, buffer_offset))
buffer_sent = true;
buffer_offset = 0;
}
this._detach() this._detach()
this.push(null) this.push(null)
return cb(); return cb();
@@ -103,11 +107,7 @@ CopyStreamQuery.prototype._transform = function(chunk, enc, cb) {
} }
} }
if(needPush && !buffer_sent && buffer_offset > 0) { this.pushBufferIfneeded();
this.push(buffer.slice(0, buffer_offset))
buffer_sent = true;
buffer_offset = 0;
}
if(chunk.length - offset) { if(chunk.length - offset) {
var slice = chunk.slice(offset) var slice = chunk.slice(offset)