stream-to-promise - npm Package Compare versions

Comparing version 0.0.4 to 0.0.5

index.js

@@ -5,3 +5,5 @@ var toArray = require('stream-to-array');
 module.exports = function (stream) {
-  return Promise.promisify(toArray)(stream)
+  var promise = Promise.promisify(toArray)(stream)
+  stream.resume();
+  return promise
     .map(function (part) {
@@ -8,0 +10,0 @@ return (part instanceof Buffer) ? part : new Buffer(part);

package.json

 {
   "name": "stream-to-promise",
-  "version": "0.0.4",
+  "version": "0.0.5",
   "description": "Convert readable streams to promises",
@@ -30,4 +30,5 @@ "main": "index.js",
     "chai": "~1.9.0",
-    "mocha": "~1.18.2"
+    "mocha": "~1.18.2",
+    "delayed-stream": "0.0.5"
   }
 }

test.js

@@ -6,2 +6,3 @@ 'use strict';
 var Promise         = require('bluebird');
+var DelayedStream   = require('delayed-stream');
 var streamToPromise = require('./');
@@ -61,2 +62,11 @@
 
+  it('ensures that streams are flowing (#1)', function () {
+    var delayed = DelayedStream.create(stream);
+    stream.emit('data', new Buffer('foo'));
+    stream.emit('end');
+    return streamToPromise(delayed).then(function (buffer) {
+      expect(buffer.toString()).to.equal('foo');
+    });
+  });
+
   it('rejects on stream errors', function () {
@@ -63,0 +73,0 @@ var err = new Error();

No alert changes

Improved metrics

Total package byte prevSize

5580

increased by8.22%

Lines of code

75

increased by17.19%

Worsened metrics

Dev dependency count

4

increased by33.33%

No dependency changes