@microsoft/stream-collator - npm Package Compare versions

Comparing version 2.0.2 to 2.0.3

CHANGELOG.json

@@ -5,2 +5,19 @@ {
     {
+      "version": "2.0.3",
+      "tag": "@microsoft/stream-collator_v2.0.3",
+      "date": "Tue, 25 Jul 2017 20:03:31 GMT",
+      "comments": {
+        "patch": [
+          {
+            "comment": "Upgrade to TypeScript 2.4"
+          }
+        ],
+        "dependency": [
+          {
+            "comment": "Updating dependency \"@microsoft/node-library-build\" from `~3.1.0` to `~3.2.0`"
+          }
+        ]
+      }
+    },
+    {
       "version": "2.0.2",
@@ -7,0 +24,0 @@ "tag": "@microsoft/stream-collator_v2.0.2",

CHANGELOG.md

 # Change Log - @microsoft/stream-collator
 
-This log was last generated on Fri, 23 Jun 2017 20:05:07 GMT and should not be manually modified.
+This log was last generated on Tue, 25 Jul 2017 20:03:31 GMT and should not be manually modified.
 
+## 2.0.3
+Tue, 25 Jul 2017 20:03:31 GMT
+
+### Patches
+
+- Upgrade to TypeScript 2.4
+
 ## 2.0.2
@@ -6,0 +13,0 @@ Fri, 23 Jun 2017 20:05:07 GMT

lib/index.js

@@ -0,4 +1,4 @@
+"use strict";
 // Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT license.
 // See LICENSE in the project root for license information.
-"use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -5,0 +5,0 @@ var Interleaver_1 = require("./Interleaver");

lib/Interleaver.js

@@ -0,4 +1,4 @@
+"use strict";
 // Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT license.
 // See LICENSE in the project root for license information.
-"use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -158,9 +158,9 @@ var colors = require("colors");
     };
+    Interleaver._tasks = new Map();
+    Interleaver._activeTask = undefined;
+    Interleaver._stdout = process.stdout;
     return Interleaver;
 }());
-Interleaver._tasks = new Map();
-Interleaver._activeTask = undefined;
-Interleaver._stdout = process.stdout;
 exports.default = Interleaver;
 
 //# sourceMappingURL=Interleaver.js.map

lib/next/DualTaskStream.js

@@ -0,4 +1,4 @@
+"use strict";
 // Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT license.
 // See LICENSE in the project root for license information.
-"use strict";
 var __extends = (this && this.__extends) || (function () {
@@ -5,0 +5,0 @@ var extendStatics = Object.setPrototypeOf ||

lib/next/PersistentStream.js

@@ -0,4 +1,4 @@
+"use strict";
 // Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT license.
 // See LICENSE in the project root for license information.
-"use strict";
 var __extends = (this && this.__extends) || (function () {
@@ -5,0 +5,0 @@ var extendStatics = Object.setPrototypeOf ||

lib/next/StreamCollator.d.ts

 /// <reference types="node" />
-import * as stream from 'stream';
+import * as Stream from 'stream';
 /**
  * A class which manages the output of multiple threads.
  */
-export default class StreamCollator<T extends NodeJS.ReadableStream> extends stream.Readable implements NodeJS.ReadableStream {
+export default class StreamCollator<T extends NodeJS.ReadableStream> extends Stream.Readable implements NodeJS.ReadableStream {
     private _streams;
@@ -8,0 +8,0 @@ private _activeStream;

lib/next/StreamCollator.js

@@ -0,4 +1,4 @@
+"use strict";
 // Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT license.
 // See LICENSE in the project root for license information.
-"use strict";
 var __extends = (this && this.__extends) || (function () {
@@ -16,3 +16,3 @@ var extendStatics = Object.setPrototypeOf ||
 /* istanbul ignore next */
-var stream = require("stream");
+var Stream = require("stream");
 var StreamState;
@@ -51,3 +51,2 @@ (function (StreamState) {
     };
-    ;
     /**
@@ -68,5 +67,5 @@ * Registers a stream into the list of active buffers.
         for (var _i = 0, _a = this._streams; _i < _a.length; _i++) {
-            var stream_1 = _a[_i];
-            if (stream_1.state === StreamState.Open && stream_1 !== this._activeStream) {
-                return stream_1;
+            var stream = _a[_i];
+            if (stream.state === StreamState.Open && stream !== this._activeStream) {
+                return stream;
             }
@@ -80,7 +79,7 @@ }
         if (!this._activeStream) {
-            var stream_2 = this._findActiveTaskCandidate();
-            this._activeStream = stream_2;
+            var stream = this._findActiveTaskCandidate();
+            this._activeStream = stream;
             // In some cases there may be no streams which we can make active
-            if (stream_2) {
-                this._writeTaskBuffer(stream_2);
+            if (stream) {
+                this._writeTaskBuffer(stream);
             }
@@ -152,6 +151,6 @@ }
         for (var _i = 0, _a = this._streams; _i < _a.length; _i++) {
-            var stream_3 = _a[_i];
-            if (stream_3 && stream_3.state === StreamState.ClosedUnwritten) {
-                this._writeTaskBuffer(stream_3);
-                stream_3.state = StreamState.Written;
+            var stream = _a[_i];
+            if (stream && stream.state === StreamState.ClosedUnwritten) {
+                this._writeTaskBuffer(stream);
+                stream.state = StreamState.Written;
             }
@@ -161,5 +160,5 @@ }
     return StreamCollator;
-}(stream.Readable));
+}(Stream.Readable));
 exports.default = StreamCollator;
 
 //# sourceMappingURL=StreamCollator.js.map

lib/next/test/DualTaskStream.test.js

@@ -0,4 +1,4 @@
+"use strict";
 // Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT license.
 // See LICENSE in the project root for license information.
-"use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -5,0 +5,0 @@ /// <reference types="mocha" />

lib/next/test/PersistentStream.test.js

@@ -0,4 +1,4 @@
+"use strict";
 // Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT license.
 // See LICENSE in the project root for license information.
-"use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -5,0 +5,0 @@ /// <reference types="mocha" />

lib/next/test/StreamModerator.test.js

@@ -0,4 +1,4 @@
+"use strict";
 // Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT license.
 // See LICENSE in the project root for license information.
-"use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -5,0 +5,0 @@ /// <reference types="mocha" />

lib/test/Interleaver.test.js

@@ -0,4 +1,4 @@
+"use strict";
 // Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT license.
 // See LICENSE in the project root for license information.
-"use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -5,0 +5,0 @@ /// <reference types="mocha" />

package.json

 {
   "name": "@microsoft/stream-collator",
-  "version": "2.0.2",
+  "version": "2.0.3",
   "description": "Display intelligible realtime output from your asynchronous streams",
@@ -27,5 +27,5 @@ "repository": {
     "gulp": "~3.9.1",
-    "mocha": "~2.5.3",
-    "@microsoft/node-library-build": ">=3.0.1 <4.0.0"
+    "mocha": "~3.4.2",
+    "@microsoft/node-library-build": "~3.2.0"
   }
 }

No alert changes

Improved metrics

Total package byte prevSize

110372

increased by0.45%

Lines of code

1116

increased by1.45%

No dependency changes