# Pastebin eJwmktt7
module.exports.createFunctionStream = createFunctionStream

function createFunctionStream(func) {
  var funcStr = func + ';\n return this;'
  if (func[0] === '{') funcStr = 'var that = ' + func + ';\n return that;'
  var compiled = new Function(funcStr)
  
  function transform(obj, enc, next) {
    var out = compiled.call(obj, obj)
    this.push(out)
    next()
  }

  return through.obj(transform)
}