gistfile1.js

function takeWhile(stream, iterator) {
  var s = through(function (chunk) {
    var keepReading = iterator(chunk)
    if (keepReading === false) {
      stream.destroy()
      this.emit("end")
    }
  })

  return stream.pipe(s)
}