stream-slicer - npm Package Compare versions

Comparing version 0.0.1 to 0.0.2

index.js

@@ -6,2 +6,5 @@ var Transform = require('stream').Transform;
 function StreamSlicer(options) {
+	if (!(this instanceof StreamSlicer))
+    	return new StreamSlicer(options);
+
 	Transform.call(this, options);
@@ -8,0 +11,0 @@ this._buffer = [];

package.json

 {
   "name": "stream-slicer",
-  "version": "0.0.1",
+  "version": "0.0.2",
   "description": "Slice another stream via a transform stream",
@@ -5,0 +5,0 @@ "main": "index.js",

test/StreamSlicer.test.js

 var assert = require('assert');
 var StreamSlicer = require('../index');
 var fs = require('fs');
+var path = require('path');
 
-var testdata = fs.readFileSync('./testdata', 'utf8');
 
+var dir = process.cwd();
+var testdataFilename;
+
+if (dir.substr(-5) === 'test/')
+	testdataFilename = './testdata';
+else
+	testdataFilename = path.join(dir, 'test', 'testdata');
+
+testdata = fs.readFileSync(testdataFilename, 'utf8');
+
 describe('StreamSlicer', function () {
@@ -12,3 +22,3 @@
 		var stream = new StreamSlicer({ sliceBy: '|' });		
-		var incoming = fs.createReadStream('./testdata');
+		var incoming = fs.createReadStream(testdataFilename);
 
@@ -25,19 +35,16 @@ var slicerOutput = '';
 
-		incoming.pipe(stream);
+		function readMore() {
+			var result = stream.read();
 
-		incoming.on('end', function () {
-
-			function readMore() {
-				var result = stream.read();
-
-				if (result === false) {
-					stream.on('readable', readMore)
-				} else {
-					slicerOutput += result;
-				}
+			if (result === null) {				
+				stream.once('readable', readMore)
+			} else {				
+				slicerOutput += result;				
+				readMore();
 			}
+		}
 
-			readMore();
+		readMore();
 
-		});
+		incoming.pipe(stream);
 	});
@@ -48,3 +55,3 @@
 		var stream = new StreamSlicer({ sliceBy: '|', replaceWith: '-' });		
-		var incoming = fs.createReadStream('./testdata');
+		var incoming = fs.createReadStream(testdataFilename);
 
@@ -61,19 +68,17 @@ var slicerOutput = '';
 
-		incoming.pipe(stream);
 
-		incoming.on('end', function () {
-
-			function readMore() {
-				var result = stream.read();
-
-				if (result === false) {
-					stream.on('readable', readMore)
-				} else {
-					slicerOutput += result;
-				}
+		function readMore() {
+			var result = stream.read();
+			
+			if (result === null) {
+				stream.once('readable', readMore)
+			} else {
+				slicerOutput += result;				
+				readMore();
 			}
+		}
 
-			readMore();
+		readMore();
 
-		});
+		incoming.pipe(stream);
 	});
@@ -84,3 +89,3 @@
 		var stream = new StreamSlicer({ sliceBy: '|' });		
-		var incoming = fs.createReadStream('./testdata');
+		var incoming = fs.createReadStream(testdataFilename);
 
@@ -87,0 +92,0 @@ var slicerOutput = [];

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

4777

increased by5.59%

Lines of code

121

increased by6.14%

No dependency changes