unique-stream - npm Package Compare versions

Comparing version 0.0.2 to 0.0.3

index.js

@@ -35,3 +35,3 @@ var Stream = require('stream');
     ended++;
-    if (ended == pipes) {
+    if (ended === pipes || pipes === 0) {
       s.writable = false;
@@ -38,0 +38,0 @@ s.emit('end');

package.json

 {
   "name": "unique-stream",
-  "version": "0.0.2",
+  "version": "0.0.3",
   "description": "node.js through stream that emits a unique stream of objects based on criteria",
@@ -5,0 +5,0 @@ "main": "index.js",

README.md

@@ -5,2 +5,4 @@ # unique-stream
 
+[![build status](https://secure.travis-ci.org/eugeneware/unique-stream.png)](http://travis-ci.org/eugeneware/unique-stream)
+
 ## Installation
@@ -7,0 +9,0 @@

test/index.js

@@ -92,2 +92,18 @@ var expect = require('chai').expect
   });
+
+  it('should be able to handle uniqueness when not piped', function(done) {
+    var stream = unique();
+    var count = 0;
+    stream.on('data', function (data) {
+      expect(data).to.equal('hello');
+      count++;
+    });
+    stream.on('end', function() {
+      expect(count).to.equal(1);
+      done();
+    });
+    stream.write('hello');
+    stream.write('hello');
+    stream.end();
+  });
 });

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

Improved metrics

Total package byte prevSize

5648

increased by11.42%

Number of package files

6

increased by20%

Lines of code

141

increased by11.9%

Number of lines in readme file

90

increased by2.27%

No dependency changes