Knex update stream

knex-update-stream.js

var stream = require('stream')
var util = require('util')

module.exports = UpdateStream

util.inherits(UpdateStream, stream.Writable)
function UpdateStream (trx, tableName, transformMethod) {
  stream.Writable.call(this, {objectMode: true})
  this.trx = trx
  this.tableName = tableName
  this.transoformMethod = transformMethod || function (chunk, cb) { cb(null, chunk) }
}

UpdateStream.prototype._write = function write (chunk, encoding, done) {
  var self = this
  this.transformMethod(chunk, function (err, chunk) {
    self.trx(self.tableName)
      .transacting(self.trx)
      .update(chunk.update)
      .where(chunk.where)
      .asCallback(done)
  })
}