@microsoft/stream-collator - npm Package Compare versions

Comparing version 1.0.1 to 1.0.2

lib/next/DualTaskStream.d.ts

@@ -0,1 +1,2 @@
+/// <reference types="node" />
 import * as stream from 'stream';
@@ -2,0 +3,0 @@ import PersistentStream from './PersistentStream';

lib/next/PersistentStream.d.ts

@@ -0,1 +1,2 @@
+/// <reference types="node" />
 /**
@@ -2,0 +3,0 @@ * @file PersistentStream.ts

lib/next/StreamCollator.d.ts

@@ -0,1 +1,2 @@
+/// <reference types="node" />
 /**
@@ -2,0 +3,0 @@ * @file StreamCollator.ts

lib/next/test/DualTaskStream.test.js

@@ -0,6 +1,6 @@
+/// <reference types="mocha" />
 "use strict";
-var chai = require('chai');
+var chai_1 = require('chai');
 var colors = require('colors');
 var DualTaskStream_1 = require('../DualTaskStream');
-var assert = chai.assert;
 var helloWorld = 'Hello, world!';
@@ -11,3 +11,3 @@ describe('DualTaskStream', function () {
         stream.on('data', function (data) {
-            assert.equal(data.toString(), helloWorld);
+            chai_1.assert.equal(data.toString(), helloWorld);
             done();
@@ -20,3 +20,3 @@ });
         stream.on('data', function (data) {
-            assert.equal(data.toString(), colors.red(helloWorld));
+            chai_1.assert.equal(data.toString(), colors.red(helloWorld));
             done();
@@ -30,4 +30,4 @@ });
         stream.on('data', function (data) {
-            assert.equal(data.toString(), colors.yellow(helloWorld));
-            assert.equal(stream.stdout.readAll(), colors.yellow(helloWorld));
+            chai_1.assert.equal(data.toString(), colors.yellow(helloWorld));
+            chai_1.assert.equal(stream.stdout.readAll(), colors.yellow(helloWorld));
             done();
@@ -41,3 +41,3 @@ });
         stream.stdout.end();
-        assert.isNull(stream.read());
+        chai_1.assert.isNull(stream.read());
         done();
@@ -50,3 +50,3 @@ });
         stream.stderr.end();
-        assert.isNull(stream.read());
+        chai_1.assert.isNull(stream.read());
         done();
@@ -115,3 +115,3 @@ });
             if (stderrClosed && stdoutClosed) {
-                assert.doesNotThrow(function () { stream.end(); });
+                chai_1.assert.doesNotThrow(function () { stream.end(); });
                 done();
@@ -118,0 +118,0 @@ }

lib/next/test/PersistentStream.test.js

@@ -0,5 +1,5 @@
+/// <reference types="mocha" />
 "use strict";
-var chai = require('chai');
+var chai_1 = require('chai');
 var PersistentStream_1 = require('../PersistentStream');
-var assert = chai.assert;
 describe('PersistentStream', function () {
@@ -10,3 +10,3 @@ it('passes through unmodified values', function (done) {
         stream.on('data', function (data) {
-            assert.equal(data.toString(), text);
+            chai_1.assert.equal(data.toString(), text);
             done();
@@ -20,5 +20,5 @@ });
         stream.write('2');
-        assert.equal(stream.readAll(), '12');
+        chai_1.assert.equal(stream.readAll(), '12');
         stream.end();
-        assert.equal(stream.readAll(), '12');
+        chai_1.assert.equal(stream.readAll(), '12');
         done();
@@ -25,0 +25,0 @@ });

lib/next/test/StreamModerator.test.js

@@ -0,6 +1,6 @@
+/// <reference types="mocha" />
 "use strict";
-var chai = require('chai');
+var chai_1 = require('chai');
 var StreamCollator_1 = require('../StreamCollator');
 var PersistentStream_1 = require('../PersistentStream');
-var assert = chai.assert;
 var collator;
@@ -23,3 +23,3 @@ var stdout, taskA, taskB;
         testWrite(taskA, text, stdout, 'data', function () {
-            assert.equal(stdout.readAll(), text);
+            chai_1.assert.equal(stdout.readAll(), text);
             done();
@@ -30,12 +30,12 @@ });
         testWrite(taskA, '1', collator, 'data', function () {
-            assert.equal(stdout.readAll(), '1');
+            chai_1.assert.equal(stdout.readAll(), '1');
             taskB.write('2');
             testWrite(taskA, '3', stdout, 'data', function () {
-                assert.equal(stdout.readAll(), '13');
+                chai_1.assert.equal(stdout.readAll(), '13');
                 taskA.end();
-                assert.equal(stdout.readAll(), '13');
+                chai_1.assert.equal(stdout.readAll(), '13');
                 testEnd(taskB, taskB, 'end', function () {
-                    assert.equal(stdout.readAll(), '132');
-                    assert.equal(taskA.readAll(), '13');
-                    assert.equal(taskB.readAll(), '2');
+                    chai_1.assert.equal(stdout.readAll(), '132');
+                    chai_1.assert.equal(taskA.readAll(), '13');
+                    chai_1.assert.equal(taskB.readAll(), '2');
                     done();
@@ -48,12 +48,12 @@ });
         testWrite(taskA, '1', stdout, 'data', function () {
-            assert.equal(stdout.readAll(), '1');
+            chai_1.assert.equal(stdout.readAll(), '1');
             taskB.write('2');
             testWrite(taskA, '3', stdout, 'data', function () {
-                assert.equal(stdout.readAll(), '13');
+                chai_1.assert.equal(stdout.readAll(), '13');
                 taskA.end();
-                assert.equal(stdout.readAll(), '13');
+                chai_1.assert.equal(stdout.readAll(), '13');
                 testEnd(taskB, collator, 'end', function () {
-                    assert.equal(stdout.readAll(), '132');
-                    assert.equal(taskA.readAll(), '13');
-                    assert.equal(taskB.readAll(), '2');
+                    chai_1.assert.equal(stdout.readAll(), '132');
+                    chai_1.assert.equal(taskA.readAll(), '13');
+                    chai_1.assert.equal(taskB.readAll(), '2');
                     done();
@@ -66,11 +66,11 @@ });
         testWrite(taskA, '1', collator, 'data', function () {
-            assert.equal(stdout.readAll(), '1');
+            chai_1.assert.equal(stdout.readAll(), '1');
             taskA.end();
-            assert.equal(stdout.readAll(), '1');
+            chai_1.assert.equal(stdout.readAll(), '1');
             testWrite(taskB, '2', stdout, 'data', function () {
-                assert.equal(stdout.readAll(), '12');
+                chai_1.assert.equal(stdout.readAll(), '12');
                 testEnd(taskB, stdout, 'data', function () {
-                    assert.equal(stdout.readAll(), '12');
-                    assert.equal(taskA.readAll(), '1');
-                    assert.equal(taskB.readAll(), '2');
+                    chai_1.assert.equal(stdout.readAll(), '12');
+                    chai_1.assert.equal(taskA.readAll(), '1');
+                    chai_1.assert.equal(taskB.readAll(), '2');
                     done();
@@ -83,12 +83,12 @@ });
         testWrite(taskA, '1', collator, 'data', function () {
-            assert.equal(stdout.readAll(), '1');
+            chai_1.assert.equal(stdout.readAll(), '1');
             taskB.write('2');
-            assert.equal(stdout.readAll(), '1');
+            chai_1.assert.equal(stdout.readAll(), '1');
             testEnd(taskB, taskB, 'end', function () {
-                assert.equal(stdout.readAll(), '1');
+                chai_1.assert.equal(stdout.readAll(), '1');
                 testEnd(taskA, taskA, 'end', function () {
                     testActionOnStream(function () { }, stdout, 'data', function () {
-                        assert.equal(stdout.readAll(), '12');
-                        assert.equal(taskA.readAll(), '1');
-                        assert.equal(taskB.readAll(), '2');
+                        chai_1.assert.equal(stdout.readAll(), '12');
+                        chai_1.assert.equal(taskA.readAll(), '1');
+                        chai_1.assert.equal(taskB.readAll(), '2');
                         done();
@@ -95,0 +95,0 @@ });

lib/test/Interleaver.test.js

@@ -0,7 +1,7 @@
+/// <reference types="mocha" />
 "use strict";
-var chai = require('chai');
+var chai_1 = require('chai');
 var colors = require('colors');
 var os = require('os');
 var Interleaver_1 = require('../Interleaver');
-var assert = chai.assert;
 var StringStream = (function () {
@@ -32,3 +32,3 @@ function StringStream() {
         it('cannot be directly instantiated', function (done) {
-            assert.throws(function () {
+            chai_1.assert.throws(function () {
                 /* tslint:disable:no-unused-variable */
@@ -42,3 +42,3 @@ var a = new Interleaver_1.default();
             var helloWorldWriter = Interleaver_1.default.registerTask('Hello World');
-            assert.isObject(helloWorldWriter);
+            chai_1.assert.isObject(helloWorldWriter);
             done();
@@ -48,4 +48,4 @@ });
             var taskName = 'Hello World';
-            assert.doesNotThrow(function () { Interleaver_1.default.registerTask(taskName); });
-            assert.throws(function () { Interleaver_1.default.registerTask(taskName); });
+            chai_1.assert.doesNotThrow(function () { Interleaver_1.default.registerTask(taskName); });
+            chai_1.assert.throws(function () { Interleaver_1.default.registerTask(taskName); });
             done();
@@ -57,3 +57,3 @@ });
             task.close();
-            assert.throws(task.close);
+            chai_1.assert.throws(task.close);
             done();
@@ -65,3 +65,3 @@ });
             task.close();
-            assert.throws(function () { task.write('1'); });
+            chai_1.assert.throws(function () { task.write('1'); });
             done();
@@ -75,3 +75,3 @@ });
             taskA.writeLine(text);
-            assert.equal(taskA.getStdOutput(), text + os.EOL);
+            chai_1.assert.equal(taskA.getStdOutput(), text + os.EOL);
             done();
@@ -83,6 +83,6 @@ });
             taskA.writeError(warning);
-            assert.equal(stdout.read(), colors.yellow(warning));
+            chai_1.assert.equal(stdout.read(), colors.yellow(warning));
             taskA.close();
-            assert.equal(taskA.getStdOutput(), warning);
-            assert.equal(taskA.getStdError(), '');
+            chai_1.assert.equal(taskA.getStdOutput(), warning);
+            chai_1.assert.equal(taskA.getStdError(), '');
             done();
@@ -94,6 +94,6 @@ });
             taskA.writeError(error);
-            assert.equal(stdout.read(), colors.red(error));
+            chai_1.assert.equal(stdout.read(), colors.red(error));
             taskA.close();
-            assert.equal(taskA.getStdOutput(), '');
-            assert.equal(taskA.getStdError(), error);
+            chai_1.assert.equal(taskA.getStdOutput(), '');
+            chai_1.assert.equal(taskA.getStdError(), error);
             done();
@@ -107,13 +107,13 @@ });
             taskA.write('1');
-            assert.equal(stdout.read(), '1');
+            chai_1.assert.equal(stdout.read(), '1');
             taskB.write('2');
-            assert.equal(stdout.read(), '1');
+            chai_1.assert.equal(stdout.read(), '1');
             taskA.write('3');
-            assert.equal(stdout.read(), '13');
+            chai_1.assert.equal(stdout.read(), '13');
             taskA.close();
-            assert.equal(stdout.read(), '13');
+            chai_1.assert.equal(stdout.read(), '13');
             taskB.close();
-            assert.equal(stdout.read(), '132');
-            assert.equal(taskA.getStdOutput(), '13');
-            assert.equal(taskB.getStdOutput(), '2');
+            chai_1.assert.equal(stdout.read(), '132');
+            chai_1.assert.equal(taskA.getStdOutput(), '13');
+            chai_1.assert.equal(taskB.getStdOutput(), '2');
             done();
@@ -125,13 +125,13 @@ });
             taskA.write('1');
-            assert.equal(stdout.read(), '');
+            chai_1.assert.equal(stdout.read(), '');
             taskB.write('2');
-            assert.equal(stdout.read(), '');
+            chai_1.assert.equal(stdout.read(), '');
             taskA.write('3');
-            assert.equal(stdout.read(), '');
+            chai_1.assert.equal(stdout.read(), '');
             taskA.close();
-            assert.equal(stdout.read(), '');
+            chai_1.assert.equal(stdout.read(), '');
             taskB.close();
-            assert.equal(stdout.read(), '');
-            assert.equal(taskA.getStdOutput(), '13');
-            assert.equal(taskB.getStdOutput(), '2');
+            chai_1.assert.equal(stdout.read(), '');
+            chai_1.assert.equal(taskA.getStdOutput(), '13');
+            chai_1.assert.equal(taskB.getStdOutput(), '2');
             done();
@@ -143,11 +143,11 @@ });
             taskA.write('1');
-            assert.equal(stdout.read(), '1');
+            chai_1.assert.equal(stdout.read(), '1');
             taskA.close();
-            assert.equal(stdout.read(), '1');
+            chai_1.assert.equal(stdout.read(), '1');
             taskB.write('2');
-            assert.equal(stdout.read(), '12');
+            chai_1.assert.equal(stdout.read(), '12');
             taskB.close();
-            assert.equal(stdout.read(), '12');
-            assert.equal(taskA.getStdOutput(), '1');
-            assert.equal(taskB.getStdOutput(), '2');
+            chai_1.assert.equal(stdout.read(), '12');
+            chai_1.assert.equal(taskA.getStdOutput(), '1');
+            chai_1.assert.equal(taskB.getStdOutput(), '2');
             done();
@@ -159,11 +159,11 @@ });
             taskA.write('1');
-            assert.equal(stdout.read(), '1');
+            chai_1.assert.equal(stdout.read(), '1');
             taskB.write('2');
-            assert.equal(stdout.read(), '1');
+            chai_1.assert.equal(stdout.read(), '1');
             taskB.close();
-            assert.equal(stdout.read(), '1');
+            chai_1.assert.equal(stdout.read(), '1');
             taskA.close();
-            assert.equal(stdout.read(), '12');
-            assert.equal(taskA.getStdOutput(), '1');
-            assert.equal(taskB.getStdOutput(), '2');
+            chai_1.assert.equal(stdout.read(), '12');
+            chai_1.assert.equal(taskA.getStdOutput(), '1');
+            chai_1.assert.equal(taskB.getStdOutput(), '2');
             done();
@@ -170,0 +170,0 @@ });

package.json

 {
   "name": "@microsoft/stream-collator",
-  "version": "1.0.1",
+  "version": "1.0.2",
   "description": "Display intelligible realtime output from your asynchronous streams",
@@ -9,15 +9,19 @@ "main": "lib/index.js",
     "build": "gulp",
-    "test": "gulp",
-    "clean": "gulp nuke"
+    "test": "gulp test",
+    "clean": "gulp clean"
   },
   "license": "SEE LICENSE IN LICENSE.docx",
   "dependencies": {
-    "colors": "~1.1.2"
+    "colors": "~1.1.2",
+    "@types/node": ">=6.0.51 <6.9.1"
   },
   "devDependencies": {
+    "@types/chai": ">=3.4.34 <3.6.0",
+    "@types/mocha": ">=2.2.33 <2.6.0",
+    "@types/es6-collections": "^0.5.29",
     "chai": "~3.5.0",
     "gulp": "~3.9.1",
     "mocha": "~2.5.3",
-    "@microsoft/sp-build-node": "~0.1.0"
+    "@microsoft/sp-build-node": "~0.2.0"
   }
-}
+}

Fixed alerts

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

151433

increased by0.83%

Number of package files

33

increased by6.45%

Lines of code

1052

increased by1.84%

Number of medium supply chain risk alerts

0

decreased by-100%

Worsened metrics

Dependency count

2

increased by100%

Dev dependency count

7

increased by75%

Dependency changes

• + Added@types/node@>=6.0.51 <6.9.1

• + Added@types/node@6.0.118(transitive)