index.js 409 B

1234567891011121314151617181920212223
  1. module.exports = function streamToBuffer(stream, callback) {
  2. var done = false
  3. var buffers = []
  4. stream.on('data', function (data) {
  5. buffers.push(data)
  6. })
  7. stream.on('end', function () {
  8. if (done)
  9. return
  10. done = true
  11. callback(null, Buffer.concat(buffers))
  12. buffers = null
  13. })
  14. stream.on('error', function (err) {
  15. done = true
  16. buffers = null
  17. callback(err)
  18. })
  19. }