merge-stream - npm Package Compare versions

Comparing version 0.1.1 to 0.1.2

index.js

@@ -1,37 +0,31 @@
-var Stream = require('stream');
+'use strict'
 
+var through = require('through2')
+
 module.exports = function (/*streams...*/) {
-  var sources = [];
-  var stream  = new Stream();
+  var firstTick = true;
+  var sources = []
+  var output  = through.obj()
 
-  stream.writable = stream.readable = true;
+  output.setMaxListeners(0)
 
-  [].slice.call(arguments).forEach(addStream);
+  output.add = add
 
-  stream.add = addStream;
+  output.on('unpipe', remove)
 
-  stream.write = function (data) {
-    this.emit('data', data)
-  }
+  Array.prototype.slice.call(arguments).forEach(add)
 
-  stream.destroy = function () {
-    sources.forEach(function (e) {
-      if (e.destroy) e.destroy()
-    })
+  return output
+
+  function add (source) {
+    sources.push(source)
+    source.once('end', remove.bind(null, source))
+    source.pipe(output, {end: false})
+    return source
   }
 
-  return stream
-
-  function addStream(e) {
-    sources.push(e);
-    e.pipe(stream, {end: false})
-    var ended = false
-    e.on('end', function () {
-      if (ended) return
-      ended = true
-      sources = sources.filter(function (it) { return it !== e })
-      if (!sources.length) stream.emit('end')
-    })
-    return e;
+  function remove (source) {
+    sources = sources.filter(function (it) { return it !== source })
+    if (!sources.length && output.readable) { output.emit('end') }
   }
 }

package.json

 {
   "name": "merge-stream",
-  "version": "0.1.1",
+  "version": "0.1.2",
   "description": "Create a stream that emits events from multiple other streams",
   "main": "index.js",
   "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1"
+    "test": "istanbul cover test.js && istanbul check-cover --statements 100 --branches 100"
   },
   "repository": "grncdr/merge-stream",
   "author": "Stephen Sugden <[e-mail]>",
-  "license": "MIT"
+  "license": "MIT",
+  "dependencies": {
+    "through2": "^0.5.1"
+  },
+  "devDependencies": {
+    "from2": "0.0.0",
+    "istanbul": "^0.2.12"
+  }
 }

README.md

 # merge-stream
 
+Merge (interleave) a bunch of streams.
+
+[![build status](https://secure.travis-ci.org/grncdr/merge-stream.svg?branch=master)](http://travis-ci.org/grncdr/merge-stream)
+
 ## Synopsis
@@ -4,0 +8,0 @@

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

No tests

Quality

Package does not have any tests. This is a strong signal of a poorly maintained or low quality package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

4355

increased by182.98%

Number of package files

8

increased by166.67%

Lines of code

111

increased by282.76%

Number of low quality alerts

2

decreased by-33.33%

Number of lines in readme file

26

increased by18.18%

Worsened metrics

Dependency count

1

increased byInfinity%

Dev dependency count

2

increased byInfinity%

Dependency changes

• + Addedthrough2@^0.5.1

• + Addedcore-util-is@1.0.3(transitive)

• + Addedinherits@2.0.4(transitive)

• + Addedisarray@0.0.1(transitive)

• + Addedreadable-stream@1.0.34(transitive)

• + Addedstring_decoder@0.10.31(transitive)

• + Addedthrough2@0.5.1(transitive)

• + Addedxtend@3.0.0(transitive)