node_modules

1 files changed, 21 insertions, 29 deletions

diff --git a/node_modules/get-stream/index.js b/node_modules/get-stream/index.js
index aa60cf038..2dc5ee96a 100644
--- a/node_modules/get-stream/index.js
+++ b/node_modules/get-stream/index.js
@@ -1,24 +1,31 @@
 'use strict';
-var Promise = require('pinkie-promise');
-var objectAssign = require('object-assign');
-var bufferStream = require('./buffer-stream');
+const bufferStream = require('./buffer-stream');
 
 function getStream(inputStream, opts) {
 	if (!inputStream) {
 		return Promise.reject(new Error('Expected a stream'));
 	}
 
-	opts = objectAssign({maxBuffer: Infinity}, opts);
-	var maxBuffer = opts.maxBuffer;
-	var stream;
-	var clean;
+	opts = Object.assign({maxBuffer: Infinity}, opts);
+
+	const maxBuffer = opts.maxBuffer;
+	let stream;
+	let clean;
+
+	const p = new Promise((resolve, reject) => {
+		const error = err => {
+			if (err) { // null check
+				err.bufferedData = stream.getBufferedValue();
+			}
+
+			reject(err);
+		};
 
-	var p = new Promise(function (resolve, reject) {
 		stream = bufferStream(opts);
 		inputStream.once('error', error);
 		inputStream.pipe(stream);
 
-		stream.on('data', function () {
+		stream.on('data', () => {
 			if (stream.getBufferedLength() > maxBuffer) {
 				reject(new Error('maxBuffer exceeded'));
 			}
@@ -26,34 +33,19 @@ function getStream(inputStream, opts) {
 		stream.once('error', error);
 		stream.on('end', resolve);
 
-		clean = function () {
-			// some streams doesn't implement the stream.Readable interface correctly
+		clean = () => {
+			// some streams doesn't implement the `stream.Readable` interface correctly
 			if (inputStream.unpipe) {
 				inputStream.unpipe(stream);
 			}
 		};
-
-		function error(err) {
-			if (err) { // null check
-				err.bufferedData = stream.getBufferedValue();
-			}
-			reject(err);
-		}
 	});
 
 	p.then(clean, clean);
 
-	return p.then(function () {
-		return stream.getBufferedValue();
-	});
+	return p.then(() => stream.getBufferedValue());
 }
 
 module.exports = getStream;
-
-module.exports.buffer = function (stream, opts) {
-	return getStream(stream, objectAssign({}, opts, {encoding: 'buffer'}));
-};
-
-module.exports.array = function (stream, opts) {
-	return getStream(stream, objectAssign({}, opts, {array: true}));
-};
+module.exports.buffer = (stream, opts) => getStream(stream, Object.assign({}, opts, {encoding: 'buffer'}));
+module.exports.array = (stream, opts) => getStream(stream, Object.assign({}, opts, {array: true}));