stream-to-promise - npm Package Compare versions

Comparing version 1.0.4 to 1.1.0

index.js

@@ -1,43 +0,35 @@
-'use strict';
+'use strict'
 
-var toArray   = require('stream-to-array');
-var Promise   = require('bluebird');
-var internals = {};
+var toArray = require('stream-to-array')
+var Promise = require('bluebird')
 
-internals.readable = function (stream) {
-  var promise = toArray(stream);
+module.exports = streamToPromise
 
+function streamToPromise (stream) {
+  if (stream.readable) return fromReadable(stream)
+  if (stream.writable) return fromWritable(stream)
+  return Promise.resolve()
+}
+
+function fromReadable (stream) {
+  var promise = toArray(stream)
+
   // Ensure stream is in flowing mode
-  stream.resume();
+  stream.resume()
 
   return promise
-    .then(function (parts) {
-      var buffers = [];
-      for (var i = 0, l = parts.length; i < l ; ++i) {
-        var part = parts[i];
-        buffers.push((part instanceof Buffer) ? part : new Buffer(part));
-      }
-      return Buffer.concat(buffers);
-    });
-};
+    .then(function concat (parts) {
+      return Buffer.concat(parts.map(bufferize))
+    })
+}
 
-internals.writable = function (stream) {
+function fromWritable (stream) {
   return new Promise(function (resolve, reject) {
-    stream.once('finish', resolve);
-    stream.once('error', reject);
-  });
-};
+    stream.once('finish', resolve)
+    stream.once('error', reject)
+  })
+}
 
-module.exports = function (stream) {
-  var promise;
-  if (stream.readable) {
-    promise = internals.readable(stream);
-  }
-  else if (stream.writable) {
-    promise = internals.writable(stream);
-  }
-  else {
-    promise = Promise.resolve();
-  }
-  return promise;
-};
+function bufferize (chunk) {
+  return Buffer.isBuffer(chunk) ? chunk : new Buffer(chunk)
+}

package.json

 {
   "name": "stream-to-promise",
-  "version": "1.0.4",
+  "version": "1.1.0",
   "description": "Convert streams (readable or writable) to promises",
   "main": "index.js",
   "scripts": {
-    "test": "mocha test"
+    "test": "standard && mocha test.js"
   },
@@ -24,12 +24,16 @@ "repository": {
   "dependencies": {
-    "stream-to-array": "2",
-    "bluebird": "2"
+    "bluebird": "~3.0.6",
+    "stream-to-array": "~2.2.0"
   },
   "devDependencies": {
-    "chai": "1",
-    "chai-as-promised": "4",
-    "delayed-stream": "0.0.5",
-    "mocha": "1",
-    "rimraf": "2"
-  }
+    "chai": "^3.4.1",
+    "chai-as-promised": "^5.1.0",
+    "delayed-stream": "^1.0.0",
+    "mocha": "^2.3.4",
+    "rimraf": "^2.4.4",
+    "standard": "^5.4.1"
+  },
+  "files": [
+    "index.js"
+  ]
 }

No alert changes

Worsened metrics

Total package byte prevSize

3739

decreased by-1.48%

Dev dependency count

6

increased by20%

Lines of code

27

decreased by-27.03%

Dependency changes

• + Addedbluebird@3.0.6(transitive)

• + Addednative-or-bluebird@1.2.0(transitive)

• + Addedstream-to-array@2.2.1(transitive)

• - Removedany-promise@1.3.0(transitive)

• - Removedbluebird@2.11.0(transitive)

• - Removedstream-to-array@2.3.0(transitive)

• Updatedbluebird@~3.0.6

• Updatedstream-to-array@~2.2.0