Function streamToUnemptyBuffer

lib/command.js:39–68

(stream, callback)

  }

  function streamToUnemptyBuffer(stream, callback) {
    var done = false
    var buffers = []

    stream.on('data', function (data) {
      buffers.push(data)
    })

    stream.on('end', function () {
      if (done)
        return

      done = true
      let result = Buffer.concat(buffers)
      buffers = null

      if (result.length === 0) {
        const err = new Error("Stream yields empty buffer");
        callback(err, null);
      } else {
        callback(null, result);
      }
    })

    stream.on('error', function (err) {
      done = true
      buffers = null
      callback(err)
    })
  }

  proto.in = args('_in');
  proto.out = args('_out');