spawn-streaming - npm Package Compare versions

Comparing version 1.0.46 to 1.0.47

dist/cjs/lib/concatWritable.js

@@ -18,3 +18,4 @@ "use strict";
 }
-var Writable = _stream.default.Writable || _readablestream.default.Writable;
+var major = +process.versions.node.split('.')[0];
+var Writable = major > 0 ? _stream.default.Writable : _readablestream.default.Writable;
 function concatWritable(callback) {
@@ -21,0 +22,0 @@ var chunks = [];

dist/cjs/lib/concatWritable.js.map

@@ -1,1 +0,1 @@
-{"version":3,"sources":["/Users/kevin/Dev/OpenSource/node/spawn-streaming/src/lib/concatWritable.ts"],"sourcesContent":["import StreamCompat from 'readable-stream';\nimport Stream from 'stream';\n\nconst Writable = Stream.Writable || StreamCompat.Writable;\n\nexport type Callback = (lines: Buffer) => undefined;\n\nexport default function concatWritable(callback: Callback): NodeJS.WritableStream {\n  const chunks = [];\n  const stream = new Writable({\n    write: (chunk, _encoding, next) => {\n      chunks.push(chunk);\n      next();\n    },\n  });\n  stream.on('finish', () => callback(Buffer.concat(chunks.splice(0))));\n  return stream;\n}\n"],"names":["concatWritable","Writable","Stream","StreamCompat","callback","chunks","stream","write","chunk","_encoding","next","push","on","Buffer","concat","splice"],"mappings":";;;;+BAOA;;;eAAwBA;;;qEAPC;6DACN;;;;;;AAEnB,IAAMC,WAAWC,eAAM,CAACD,QAAQ,IAAIE,uBAAY,CAACF,QAAQ;AAI1C,SAASD,eAAeI,QAAkB;IACvD,IAAMC,SAAS,EAAE;IACjB,IAAMC,SAAS,IAAIL,SAAS;QAC1BM,OAAO,SAACC,OAAOC,WAAWC;YACxBL,OAAOM,IAAI,CAACH;YACZE;QACF;IACF;IACAJ,OAAOM,EAAE,CAAC,UAAU;eAAMR,SAASS,OAAOC,MAAM,CAACT,OAAOU,MAAM,CAAC;;IAC/D,OAAOT;AACT"}
+{"version":3,"sources":["/Users/kevin/Dev/OpenSource/node/spawn-streaming/src/lib/concatWritable.ts"],"sourcesContent":["import StreamCompat from 'readable-stream';\nimport Stream from 'stream';\n\nconst major = +process.versions.node.split('.')[0];\nconst Writable = major > 0 ? Stream.Writable : StreamCompat.Writable;\n\nexport type Callback = (lines: Buffer) => undefined;\n\nexport default function concatWritable(callback: Callback): NodeJS.WritableStream {\n  const chunks = [];\n  const stream = new Writable({\n    write: (chunk, _encoding, next) => {\n      chunks.push(chunk);\n      next();\n    },\n  });\n  stream.on('finish', () => callback(Buffer.concat(chunks.splice(0))));\n  return stream;\n}\n"],"names":["concatWritable","major","process","versions","node","split","Writable","Stream","StreamCompat","callback","chunks","stream","write","chunk","_encoding","next","push","on","Buffer","concat","splice"],"mappings":";;;;+BAQA;;;eAAwBA;;;qEARC;6DACN;;;;;;AAEnB,IAAMC,QAAQ,CAACC,QAAQC,QAAQ,CAACC,IAAI,CAACC,KAAK,CAAC,IAAI,CAAC,EAAE;AAClD,IAAMC,WAAWL,QAAQ,IAAIM,eAAM,CAACD,QAAQ,GAAGE,uBAAY,CAACF,QAAQ;AAIrD,SAASN,eAAeS,QAAkB;IACvD,IAAMC,SAAS,EAAE;IACjB,IAAMC,SAAS,IAAIL,SAAS;QAC1BM,OAAO,SAACC,OAAOC,WAAWC;YACxBL,OAAOM,IAAI,CAACH;YACZE;QACF;IACF;IACAJ,OAAOM,EAAE,CAAC,UAAU;eAAMR,SAASS,OAAOC,MAAM,CAACT,OAAOU,MAAM,CAAC;;IAC/D,OAAOT;AACT"}

dist/cjs/lib/prefixTransform.js

@@ -19,3 +19,4 @@ "use strict";
 }
-var Transform = _stream.default.Transform || _readablestream.default.Transform;
+var major = +process.versions.node.split('.')[0];
+var Transform = major > 0 ? _stream.default.Transform : _readablestream.default.Transform;
 var REGEX_NEW_LINE = /\r?\n|\r/g;
@@ -22,0 +23,0 @@ function prefixTransform(prefix, color) {

dist/cjs/lib/prefixTransform.js.map

@@ -1,1 +0,1 @@
-{"version":3,"sources":["/Users/kevin/Dev/OpenSource/node/spawn-streaming/src/lib/prefixTransform.ts"],"sourcesContent":["import StreamCompat from 'readable-stream';\nimport Stream from 'stream';\n\nconst Transform = Stream.Transform || StreamCompat.Transform;\n\nimport c from 'colors';\nimport type { ColorFunction } from '../types.ts';\n\nconst REGEX_NEW_LINE = /\\r?\\n|\\r/g;\n\nexport default function prefixTransform(prefix: string, color: ColorFunction): NodeJS.ReadableStream {\n  let last = '';\n\n  const createLine = (line) => `${c.bold(color(prefix))}: ${line}\\n`;\n\n  return new Transform({\n    transform(chunk, _enc, callback) {\n      const more = last + chunk.toString('utf8');\n      const lines = more.split(REGEX_NEW_LINE);\n      last = lines.pop();\n      lines.forEach((line) => this.push(createLine(line)));\n      callback();\n    },\n    flush() {\n      if (last.length) this.push(createLine(last));\n      last = '';\n      this.push(null);\n    },\n  });\n}\n"],"names":["prefixTransform","Transform","Stream","StreamCompat","REGEX_NEW_LINE","prefix","color","last","createLine","line","c","bold","transform","chunk","_enc","callback","more","toString","lines","split","pop","forEach","push","flush","length"],"mappings":";;;;+BAUA;;;eAAwBA;;;qEAVC;6DACN;6DAIL;;;;;;AAFd,IAAMC,YAAYC,eAAM,CAACD,SAAS,IAAIE,uBAAY,CAACF,SAAS;AAK5D,IAAMG,iBAAiB;AAER,SAASJ,gBAAgBK,MAAc,EAAEC,KAAoB;IAC1E,IAAIC,OAAO;IAEX,IAAMC,aAAa,SAACC;eAAS,AAAC,GAA4BA,OAA1BC,eAAC,CAACC,IAAI,CAACL,MAAMD,UAAS,MAAS,OAALI,MAAK;;IAE/D,OAAO,IAAIR,UAAU;QACnBW,WAAAA,SAAAA,UAAUC,KAAK,EAAEC,IAAI,EAAEC,QAAQ;;YAC7B,IAAMC,OAAOT,OAAOM,MAAMI,QAAQ,CAAC;YACnC,IAAMC,QAAQF,KAAKG,KAAK,CAACf;YACzBG,OAAOW,MAAME,GAAG;YAChBF,MAAMG,OAAO,CAAC,SAACZ;uBAAS,MAAKa,IAAI,CAACd,WAAWC;;YAC7CM;QACF;QACAQ,OAAAA,SAAAA;YACE,IAAIhB,KAAKiB,MAAM,EAAE,IAAI,CAACF,IAAI,CAACd,WAAWD;YACtCA,OAAO;YACP,IAAI,CAACe,IAAI,CAAC;QACZ;IACF;AACF"}
+{"version":3,"sources":["/Users/kevin/Dev/OpenSource/node/spawn-streaming/src/lib/prefixTransform.ts"],"sourcesContent":["import StreamCompat from 'readable-stream';\nimport Stream from 'stream';\n\nconst major = +process.versions.node.split('.')[0];\nconst Transform = major > 0 ? Stream.Transform : StreamCompat.Transform;\n\nimport c from 'colors';\nimport type { ColorFunction } from '../types.ts';\n\nconst REGEX_NEW_LINE = /\\r?\\n|\\r/g;\n\nexport default function prefixTransform(prefix: string, color: ColorFunction): NodeJS.ReadableStream {\n  let last = '';\n\n  const createLine = (line) => `${c.bold(color(prefix))}: ${line}\\n`;\n\n  return new Transform({\n    transform(chunk, _enc, callback) {\n      const more = last + chunk.toString('utf8');\n      const lines = more.split(REGEX_NEW_LINE);\n      last = lines.pop();\n      lines.forEach((line) => this.push(createLine(line)));\n      callback();\n    },\n    flush() {\n      if (last.length) this.push(createLine(last));\n      last = '';\n      this.push(null);\n    },\n  });\n}\n"],"names":["prefixTransform","major","process","versions","node","split","Transform","Stream","StreamCompat","REGEX_NEW_LINE","prefix","color","last","createLine","line","c","bold","transform","chunk","_enc","callback","more","toString","lines","pop","forEach","push","flush","length"],"mappings":";;;;+BAWA;;;eAAwBA;;;qEAXC;6DACN;6DAKL;;;;;;AAHd,IAAMC,QAAQ,CAACC,QAAQC,QAAQ,CAACC,IAAI,CAACC,KAAK,CAAC,IAAI,CAAC,EAAE;AAClD,IAAMC,YAAYL,QAAQ,IAAIM,eAAM,CAACD,SAAS,GAAGE,uBAAY,CAACF,SAAS;AAKvE,IAAMG,iBAAiB;AAER,SAAST,gBAAgBU,MAAc,EAAEC,KAAoB;IAC1E,IAAIC,OAAO;IAEX,IAAMC,aAAa,SAACC;eAAS,AAAC,GAA4BA,OAA1BC,eAAC,CAACC,IAAI,CAACL,MAAMD,UAAS,MAAS,OAALI,MAAK;;IAE/D,OAAO,IAAIR,UAAU;QACnBW,WAAAA,SAAAA,UAAUC,KAAK,EAAEC,IAAI,EAAEC,QAAQ;;YAC7B,IAAMC,OAAOT,OAAOM,MAAMI,QAAQ,CAAC;YACnC,IAAMC,QAAQF,KAAKhB,KAAK,CAACI;YACzBG,OAAOW,MAAMC,GAAG;YAChBD,MAAME,OAAO,CAAC,SAACX;uBAAS,MAAKY,IAAI,CAACb,WAAWC;;YAC7CM;QACF;QACAO,OAAAA,SAAAA;YACE,IAAIf,KAAKgB,MAAM,EAAE,IAAI,CAACF,IAAI,CAACb,WAAWD;YACtCA,OAAO;YACP,IAAI,CAACc,IAAI,CAAC;QACZ;IACF;AACF"}

dist/esm/lib/concatWritable.js

 import StreamCompat from 'readable-stream';
 import Stream from 'stream';
-const Writable = Stream.Writable || StreamCompat.Writable;
+const major = +process.versions.node.split('.')[0];
+const Writable = major > 0 ? Stream.Writable : StreamCompat.Writable;
 export default function concatWritable(callback) {
@@ -5,0 +6,0 @@ const chunks = [];

dist/esm/lib/concatWritable.js.map

@@ -1,1 +0,1 @@
-{"version":3,"sources":["/Users/kevin/Dev/OpenSource/node/spawn-streaming/src/lib/concatWritable.ts"],"sourcesContent":["import StreamCompat from 'readable-stream';\nimport Stream from 'stream';\n\nconst Writable = Stream.Writable || StreamCompat.Writable;\n\nexport type Callback = (lines: Buffer) => undefined;\n\nexport default function concatWritable(callback: Callback): NodeJS.WritableStream {\n  const chunks = [];\n  const stream = new Writable({\n    write: (chunk, _encoding, next) => {\n      chunks.push(chunk);\n      next();\n    },\n  });\n  stream.on('finish', () => callback(Buffer.concat(chunks.splice(0))));\n  return stream;\n}\n"],"names":["StreamCompat","Stream","Writable","concatWritable","callback","chunks","stream","write","chunk","_encoding","next","push","on","Buffer","concat","splice"],"mappings":"AAAA,OAAOA,kBAAkB,kBAAkB;AAC3C,OAAOC,YAAY,SAAS;AAE5B,MAAMC,WAAWD,OAAOC,QAAQ,IAAIF,aAAaE,QAAQ;AAIzD,eAAe,SAASC,eAAeC,QAAkB;IACvD,MAAMC,SAAS,EAAE;IACjB,MAAMC,SAAS,IAAIJ,SAAS;QAC1BK,OAAO,CAACC,OAAOC,WAAWC;YACxBL,OAAOM,IAAI,CAACH;YACZE;QACF;IACF;IACAJ,OAAOM,EAAE,CAAC,UAAU,IAAMR,SAASS,OAAOC,MAAM,CAACT,OAAOU,MAAM,CAAC;IAC/D,OAAOT;AACT"}
+{"version":3,"sources":["/Users/kevin/Dev/OpenSource/node/spawn-streaming/src/lib/concatWritable.ts"],"sourcesContent":["import StreamCompat from 'readable-stream';\nimport Stream from 'stream';\n\nconst major = +process.versions.node.split('.')[0];\nconst Writable = major > 0 ? Stream.Writable : StreamCompat.Writable;\n\nexport type Callback = (lines: Buffer) => undefined;\n\nexport default function concatWritable(callback: Callback): NodeJS.WritableStream {\n  const chunks = [];\n  const stream = new Writable({\n    write: (chunk, _encoding, next) => {\n      chunks.push(chunk);\n      next();\n    },\n  });\n  stream.on('finish', () => callback(Buffer.concat(chunks.splice(0))));\n  return stream;\n}\n"],"names":["StreamCompat","Stream","major","process","versions","node","split","Writable","concatWritable","callback","chunks","stream","write","chunk","_encoding","next","push","on","Buffer","concat","splice"],"mappings":"AAAA,OAAOA,kBAAkB,kBAAkB;AAC3C,OAAOC,YAAY,SAAS;AAE5B,MAAMC,QAAQ,CAACC,QAAQC,QAAQ,CAACC,IAAI,CAACC,KAAK,CAAC,IAAI,CAAC,EAAE;AAClD,MAAMC,WAAWL,QAAQ,IAAID,OAAOM,QAAQ,GAAGP,aAAaO,QAAQ;AAIpE,eAAe,SAASC,eAAeC,QAAkB;IACvD,MAAMC,SAAS,EAAE;IACjB,MAAMC,SAAS,IAAIJ,SAAS;QAC1BK,OAAO,CAACC,OAAOC,WAAWC;YACxBL,OAAOM,IAAI,CAACH;YACZE;QACF;IACF;IACAJ,OAAOM,EAAE,CAAC,UAAU,IAAMR,SAASS,OAAOC,MAAM,CAACT,OAAOU,MAAM,CAAC;IAC/D,OAAOT;AACT"}

dist/esm/lib/prefixTransform.js

 import StreamCompat from 'readable-stream';
 import Stream from 'stream';
-const Transform = Stream.Transform || StreamCompat.Transform;
+const major = +process.versions.node.split('.')[0];
+const Transform = major > 0 ? Stream.Transform : StreamCompat.Transform;
 import c from 'colors';
@@ -5,0 +6,0 @@ const REGEX_NEW_LINE = /\r?\n|\r/g;

dist/esm/lib/prefixTransform.js.map

@@ -1,1 +0,1 @@
-{"version":3,"sources":["/Users/kevin/Dev/OpenSource/node/spawn-streaming/src/lib/prefixTransform.ts"],"sourcesContent":["import StreamCompat from 'readable-stream';\nimport Stream from 'stream';\n\nconst Transform = Stream.Transform || StreamCompat.Transform;\n\nimport c from 'colors';\nimport type { ColorFunction } from '../types.ts';\n\nconst REGEX_NEW_LINE = /\\r?\\n|\\r/g;\n\nexport default function prefixTransform(prefix: string, color: ColorFunction): NodeJS.ReadableStream {\n  let last = '';\n\n  const createLine = (line) => `${c.bold(color(prefix))}: ${line}\\n`;\n\n  return new Transform({\n    transform(chunk, _enc, callback) {\n      const more = last + chunk.toString('utf8');\n      const lines = more.split(REGEX_NEW_LINE);\n      last = lines.pop();\n      lines.forEach((line) => this.push(createLine(line)));\n      callback();\n    },\n    flush() {\n      if (last.length) this.push(createLine(last));\n      last = '';\n      this.push(null);\n    },\n  });\n}\n"],"names":["StreamCompat","Stream","Transform","c","REGEX_NEW_LINE","prefixTransform","prefix","color","last","createLine","line","bold","transform","chunk","_enc","callback","more","toString","lines","split","pop","forEach","push","flush","length"],"mappings":"AAAA,OAAOA,kBAAkB,kBAAkB;AAC3C,OAAOC,YAAY,SAAS;AAE5B,MAAMC,YAAYD,OAAOC,SAAS,IAAIF,aAAaE,SAAS;AAE5D,OAAOC,OAAO,SAAS;AAGvB,MAAMC,iBAAiB;AAEvB,eAAe,SAASC,gBAAgBC,MAAc,EAAEC,KAAoB;IAC1E,IAAIC,OAAO;IAEX,MAAMC,aAAa,CAACC,OAAS,GAAGP,EAAEQ,IAAI,CAACJ,MAAMD,SAAS,EAAE,EAAEI,KAAK,EAAE,CAAC;IAElE,OAAO,IAAIR,UAAU;QACnBU,WAAUC,KAAK,EAAEC,IAAI,EAAEC,QAAQ;YAC7B,MAAMC,OAAOR,OAAOK,MAAMI,QAAQ,CAAC;YACnC,MAAMC,QAAQF,KAAKG,KAAK,CAACf;YACzBI,OAAOU,MAAME,GAAG;YAChBF,MAAMG,OAAO,CAAC,CAACX,OAAS,IAAI,CAACY,IAAI,CAACb,WAAWC;YAC7CK;QACF;QACAQ;YACE,IAAIf,KAAKgB,MAAM,EAAE,IAAI,CAACF,IAAI,CAACb,WAAWD;YACtCA,OAAO;YACP,IAAI,CAACc,IAAI,CAAC;QACZ;IACF;AACF"}
+{"version":3,"sources":["/Users/kevin/Dev/OpenSource/node/spawn-streaming/src/lib/prefixTransform.ts"],"sourcesContent":["import StreamCompat from 'readable-stream';\nimport Stream from 'stream';\n\nconst major = +process.versions.node.split('.')[0];\nconst Transform = major > 0 ? Stream.Transform : StreamCompat.Transform;\n\nimport c from 'colors';\nimport type { ColorFunction } from '../types.ts';\n\nconst REGEX_NEW_LINE = /\\r?\\n|\\r/g;\n\nexport default function prefixTransform(prefix: string, color: ColorFunction): NodeJS.ReadableStream {\n  let last = '';\n\n  const createLine = (line) => `${c.bold(color(prefix))}: ${line}\\n`;\n\n  return new Transform({\n    transform(chunk, _enc, callback) {\n      const more = last + chunk.toString('utf8');\n      const lines = more.split(REGEX_NEW_LINE);\n      last = lines.pop();\n      lines.forEach((line) => this.push(createLine(line)));\n      callback();\n    },\n    flush() {\n      if (last.length) this.push(createLine(last));\n      last = '';\n      this.push(null);\n    },\n  });\n}\n"],"names":["StreamCompat","Stream","major","process","versions","node","split","Transform","c","REGEX_NEW_LINE","prefixTransform","prefix","color","last","createLine","line","bold","transform","chunk","_enc","callback","more","toString","lines","pop","forEach","push","flush","length"],"mappings":"AAAA,OAAOA,kBAAkB,kBAAkB;AAC3C,OAAOC,YAAY,SAAS;AAE5B,MAAMC,QAAQ,CAACC,QAAQC,QAAQ,CAACC,IAAI,CAACC,KAAK,CAAC,IAAI,CAAC,EAAE;AAClD,MAAMC,YAAYL,QAAQ,IAAID,OAAOM,SAAS,GAAGP,aAAaO,SAAS;AAEvE,OAAOC,OAAO,SAAS;AAGvB,MAAMC,iBAAiB;AAEvB,eAAe,SAASC,gBAAgBC,MAAc,EAAEC,KAAoB;IAC1E,IAAIC,OAAO;IAEX,MAAMC,aAAa,CAACC,OAAS,GAAGP,EAAEQ,IAAI,CAACJ,MAAMD,SAAS,EAAE,EAAEI,KAAK,EAAE,CAAC;IAElE,OAAO,IAAIR,UAAU;QACnBU,WAAUC,KAAK,EAAEC,IAAI,EAAEC,QAAQ;YAC7B,MAAMC,OAAOR,OAAOK,MAAMI,QAAQ,CAAC;YACnC,MAAMC,QAAQF,KAAKf,KAAK,CAACG;YACzBI,OAAOU,MAAMC,GAAG;YAChBD,MAAME,OAAO,CAAC,CAACV,OAAS,IAAI,CAACW,IAAI,CAACZ,WAAWC;YAC7CK;QACF;QACAO;YACE,IAAId,KAAKe,MAAM,EAAE,IAAI,CAACF,IAAI,CAACZ,WAAWD;YACtCA,OAAO;YACP,IAAI,CAACa,IAAI,CAAC;QACZ;IACF;AACF"}

package.json

 {
   "name": "spawn-streaming",
-  "version": "1.0.46",
+  "version": "1.0.47",
   "description": "Formats spawn with prefix and colors",
@@ -5,0 +5,0 @@ "keywords": [

No alert changes

Improved metrics

Total package byte prevSize

46973

2.2%

Lines of code

542

0.74%

No dependency changes