New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

@microsoft/stream-collator

Package Overview
Dependencies
Maintainers
2
Versions
233
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@microsoft/stream-collator - npm Package Compare versions

Comparing version 1.0.2 to 2.0.0

EULA/Microsoft Sharepoint Framework - Standalone (free) Use Terms - Basque.docx

20

CHANGELOG.json

@@ -5,2 +5,22 @@ {

{
"version": "2.0.0",
"tag": "@microsoft/stream-collator_v2.0.0",
"date": "Fri, 17 Feb 2017 23:09:23 GMT",
"comments": {
"patch": [
{
"comment": "Locked version numbers for @types packages"
},
{
"comment": "Updated .npmignore"
}
],
"major": [
{
"comment": "General availability"
}
]
}
},
{
"version": "1.0.2",

@@ -7,0 +27,0 @@ "tag": "@microsoft/stream-collator_v1.0.2",

14

CHANGELOG.md
# Change Log - @microsoft/stream-collator
This log was last generated on Tue, 06 Dec 2016 20:44:26 GMT and should not be manually modified.
This log was last generated on Wed, 22 Feb 2017 21:16:36 GMT and should not be manually modified.
## 2.0.0
Fri, 17 Feb 2017 23:09:23 GMT
### Breaking changes
- General availability
### Patches
- Locked version numbers for @types packages
- Updated .npmignore
## 1.0.2

@@ -6,0 +18,0 @@ Tue, 06 Dec 2016 20:44:26 GMT

8

lib/index.js
"use strict";
var Interleaver_1 = require('./Interleaver');
var Interleaver_1 = require("./Interleaver");
exports.Interleaver = Interleaver_1.default;
var StreamCollator_1 = require('./next/StreamCollator');
var StreamCollator_1 = require("./next/StreamCollator");
exports.StreamCollator = StreamCollator_1.default;
var DualTaskStream_1 = require('./next/DualTaskStream');
var DualTaskStream_1 = require("./next/DualTaskStream");
exports.DualTaskStream = DualTaskStream_1.default;
var PersistentStream_1 = require('./next/PersistentStream');
var PersistentStream_1 = require("./next/PersistentStream");
exports.PersistentStream = PersistentStream_1.default;
//# sourceMappingURL=index.js.map

@@ -8,4 +8,4 @@ /**

"use strict";
var colors = require('colors');
var os = require('os');
var colors = require("colors");
var os = require("os");
var TaskWriterState;

@@ -162,7 +162,7 @@ (function (TaskWriterState) {

};
Interleaver._tasks = new Map();
Interleaver._activeTask = undefined;
Interleaver._stdout = process.stdout;
return Interleaver;
}());
Interleaver._tasks = new Map();
Interleaver._activeTask = undefined;
Interleaver._stdout = process.stdout;
Object.defineProperty(exports, "__esModule", { value: true });

@@ -169,0 +169,0 @@ exports.default = Interleaver;

@@ -14,5 +14,5 @@ /**

};
var colors = require('colors');
var stream = require('stream');
var PersistentStream_1 = require('./PersistentStream');
var colors = require("colors");
var stream = require("stream");
var PersistentStream_1 = require("./PersistentStream");
/**

@@ -29,15 +29,14 @@ * This is a special type of stream class which has two substreams (stderr and stdout), which you can write to.

function DualTaskStream(quietMode) {
var _this = this;
if (quietMode === void 0) { quietMode = false; }
_super.call(this);
this._quietMode = quietMode;
this.stdout = new PersistentStream_1.default();
this.stderr = new PersistentStream_1.default();
this.stdout.on('finish', function () {
var _this = _super.call(this) || this;
_this._quietMode = quietMode;
_this.stdout = new PersistentStream_1.default();
_this.stderr = new PersistentStream_1.default();
_this.stdout.on('finish', function () {
_this._stdoutClosed = true;
});
this.stderr.on('finish', function () {
_this.stderr.on('finish', function () {
_this._stderrClosed = true;
});
this.stdout.on('data', function (data, encoding) {
_this.stdout.on('data', function (data, encoding) {
if (!_this._quietMode) {

@@ -47,3 +46,3 @@ _this.push(data);

});
this.stderr.on('data', function (data, encoding) {
_this.stderr.on('data', function (data, encoding) {
var text = data.toString();

@@ -57,2 +56,3 @@ if (text.indexOf('Warning - ') === 0) {

});
return _this;
}

@@ -59,0 +59,0 @@ DualTaskStream.prototype._read = function () {

@@ -14,3 +14,3 @@ /**

};
var stream = require('stream');
var stream = require("stream");
/**

@@ -22,4 +22,5 @@ * A special type of strean which keeps track of everything written to it, which can be read with the readAll() function

function PersistentStream(opts) {
_super.call(this, opts);
this._buffer = [];
var _this = _super.call(this, opts) || this;
_this._buffer = [];
return _this;
}

@@ -26,0 +27,0 @@ PersistentStream.prototype._transform = function (chunk, encoding, done) {

@@ -15,3 +15,3 @@ /**

};
var stream = require('stream');
var stream = require("stream");
var StreamState;

@@ -42,5 +42,6 @@ (function (StreamState) {

function StreamCollator() {
_super.apply(this, arguments);
this._streams = [];
this._activeStream = undefined;
var _this = _super !== null && _super.apply(this, arguments) || this;
_this._streams = [];
_this._activeStream = undefined;
return _this;
}

@@ -47,0 +48,0 @@ StreamCollator.prototype._read = function () {

/// <reference types="mocha" />
"use strict";
var chai_1 = require('chai');
var colors = require('colors');
var DualTaskStream_1 = require('../DualTaskStream');
var chai_1 = require("chai");
var colors = require("colors");
var DualTaskStream_1 = require("../DualTaskStream");
var helloWorld = 'Hello, world!';

@@ -7,0 +7,0 @@ describe('DualTaskStream', function () {

/// <reference types="mocha" />
"use strict";
var chai_1 = require('chai');
var PersistentStream_1 = require('../PersistentStream');
var chai_1 = require("chai");
var PersistentStream_1 = require("../PersistentStream");
describe('PersistentStream', function () {

@@ -6,0 +6,0 @@ it('passes through unmodified values', function (done) {

/// <reference types="mocha" />
"use strict";
var chai_1 = require('chai');
var StreamCollator_1 = require('../StreamCollator');
var PersistentStream_1 = require('../PersistentStream');
var chai_1 = require("chai");
var StreamCollator_1 = require("../StreamCollator");
var PersistentStream_1 = require("../PersistentStream");
var collator;

@@ -7,0 +7,0 @@ var stdout, taskA, taskB;

/// <reference types="mocha" />
"use strict";
var chai_1 = require('chai');
var colors = require('colors');
var os = require('os');
var Interleaver_1 = require('../Interleaver');
var chai_1 = require("chai");
var colors = require("colors");
var os = require("os");
var Interleaver_1 = require("../Interleaver");
var StringStream = (function () {

@@ -8,0 +8,0 @@ function StringStream() {

{
"name": "@microsoft/stream-collator",
"version": "1.0.2",
"version": "2.0.0",
"description": "Display intelligible realtime output from your asynchronous streams",

@@ -12,16 +12,17 @@ "main": "lib/index.js",

},
"license": "SEE LICENSE IN LICENSE.docx",
"license": "SEE LICENSE IN \"EULA\" FOLDER",
"homepage": "http://aka.ms/spfx",
"dependencies": {
"colors": "~1.1.2",
"@types/node": ">=6.0.51 <6.9.1"
"@types/node": "6.0.62"
},
"devDependencies": {
"@types/chai": ">=3.4.34 <3.6.0",
"@types/mocha": ">=2.2.33 <2.6.0",
"@types/es6-collections": "^0.5.29",
"@types/chai": "3.4.34",
"@types/mocha": "2.2.38",
"@types/es6-collections": "0.5.29",
"chai": "~3.5.0",
"gulp": "~3.9.1",
"mocha": "~2.5.3",
"@microsoft/sp-build-node": "~0.2.0"
"@microsoft/sp-build-node": "~1.0.0"
}
}

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc