Function handlePart

index.js:679–695

(self, partStream)

}

function handlePart(self, partStream) {
  beginFlush(self);
  var emitAndReleaseHold = holdEmitQueue(self, partStream);
  partStream.on('end', function() {
    endFlush(self);
  });
  emitAndReleaseHold(function() {
    if (hasListeners(self, 'part')) {
      self.emit('part', partStream)
    } else {
      partStream.on('error', function (err) {
        self.handleError(err)
      })
      partStream.resume()
    }
  });
}

function handleFile(self, fileStream) {
  if (self.error) return;