collect-stream - npm Package Compare versions

Comparing version 1.1.1 to 1.2.0

index.js

 import { default as concat } from 'concat-stream';
 import { default as once } from 'once';
 
-export default function collect(stream, fn) {
+export default function collect(stream, opts, fn) {
+  if (typeof opts === 'function') {
+    fn = opts;
+    opts = {};
+  }
   fn = once(fn);
   stream.on('error', fn);
-  stream.pipe(concat(data => {
+  stream.pipe(concat(opts, data => {
     fn(null, data);
@@ -9,0 +13,0 @@ }));

package.json

 {
   "name": "collect-stream",
   "description": "Collect a readable stream's output and errors",
-  "version": "1.1.1",
+  "version": "1.2.0",
   "repository": {
@@ -6,0 +6,0 @@ "type": "git",

README.md

@@ -29,2 +29,14 @@
 
+Give it options and it will pass them to [concat-stream](https://github.com/maxogden/concat-stream/).
+
+```js
+import collect from 'collect-stream';
+
+collect(someStream, {
+  encoding: 'object'
+}, (err, data) => {
+  console.log(data) // forced to be an array of objects
+});
+```
+
 ## Installation
@@ -31,0 +43,0 @@

test.js

@@ -60,2 +60,23 @@ import { default as test } from 'tape';
 
+test('concat-stream options', t => {
+  t.plan(2);
+
+  var stream = through();
+  process.nextTick(() => {
+    stream.queue([{ foo: true }]);
+    stream.queue([{ bar: true }]);
+    stream.queue(null);
+  });
+
+  collect(stream, {
+    encoding: 'object'
+  }, (err, data) => {
+    t.error(err);
+    t.deepEqual(data, [
+      [{ foo: true }],
+      [{ bar: true }]
+    ]);
+  });
+});
+
 test('error', t => {
@@ -62,0 +83,0 @@ t.plan(1);

No alert changes

Improved metrics

Total package byte prevSize

3976

increased by3.01%

Lines of code

87

increased by3.57%

Number of lines in readme file

50

increased by31.58%

Worsened metrics

Number of package files

8

decreased by-11.11%

No dependency changes