using this.copyFromStream

This commit is contained in:
Simon Martín 2018-06-21 14:49:38 +02:00
parent 9970052e1b
commit f4651cadae

View File

@ -55,8 +55,8 @@ module.exports = class StreamCopy {
return cb(err); return cb(err);
} }
const copyFromStream = copyFrom(this.sql); this.copyFromStream = copyFrom(this.sql);
const pgstream = client.query(copyFromStream); const pgstream = client.query(this.copyFromStream);
pgstream pgstream
.on('end', () => done()) .on('end', () => done())