Simple transform stream

transform-stream

function Through(opts, onData, onEnd) {
  if (!(this instanceof Through)) return new Through(opts, onData, onEnd)
  Transform.call(this, opts)
  this._transform = onData
  if (typeof onEnd === 'function') this._flush = onEnd
}
inherits(Through, Transform)
 
function through(opts, onData, onEnd) {  
  if (typeof opts === 'function') {
    onEnd = onData || null
    onData = opts
    opts = {allowHalfOpen: false}
  }
  return Through(opts, onData, onEnd)
}