concurrently - npm Package Compare versions

Comparing version 8.2.0 to 8.2.1

dist/src/command.js

@@ -67,3 +67,5 @@ "use strict";
         });
-        Rx.fromEvent(child, 'close').subscribe(([exitCode, signal]) => {
+        Rx.fromEvent(child, 'close')
+            .pipe(Rx.map((event) => event))
+            .subscribe(([exitCode, signal]) => {
             this.process = undefined;
@@ -86,4 +88,6 @@ this.exited = true;
         });
-        child.stdout && pipeTo(Rx.fromEvent(child.stdout, 'data'), this.stdout);
-        child.stderr && pipeTo(Rx.fromEvent(child.stderr, 'data'), this.stderr);
+        child.stdout &&
+            pipeTo(Rx.fromEvent(child.stdout, 'data').pipe(Rx.map((event) => event)), this.stdout);
+        child.stderr &&
+            pipeTo(Rx.fromEvent(child.stderr, 'data').pipe(Rx.map((event) => event)), this.stderr);
         this.stdin = child.stdin || undefined;
@@ -90,0 +94,0 @@ }

dist/src/completion-listener.js

@@ -71,3 +71,3 @@ "use strict";
             ? this.emitWithScheduler(Rx.of(exitInfos))
-            : this.emitWithScheduler(Rx.throwError(exitInfos))), (0, operators_1.take)(1)));
+            : this.emitWithScheduler(Rx.throwError(() => exitInfos))), (0, operators_1.take)(1)));
     }
@@ -74,0 +74,0 @@ emitWithScheduler(input) {

dist/src/flow-control/log-timings.d.ts

@@ -25,4 +25,8 @@ import { CloseEvent, Command } from '../command';
         commands: Command[];
+        onFinish?: undefined;
+    } | {
+        commands: Command[];
+        onFinish: () => void;
     };
 }
 export {};

dist/src/flow-control/log-timings.js

@@ -86,7 +86,8 @@ "use strict";
         const closeStreams = commands.map((command) => command.close);
-        const allProcessesClosed = Rx.merge(...closeStreams).pipe((0, operators_1.bufferCount)(closeStreams.length), (0, operators_1.take)(1));
-        allProcessesClosed.subscribe((exitInfos) => this.printExitInfoTimingTable(exitInfos));
-        return { commands };
+        const finished = new Rx.Subject();
+        const allProcessesClosed = Rx.merge(...closeStreams).pipe((0, operators_1.bufferCount)(closeStreams.length), (0, operators_1.take)(1), (0, operators_1.combineLatestWith)(finished));
+        allProcessesClosed.subscribe(([exitInfos]) => this.printExitInfoTimingTable(exitInfos));
+        return { commands, onFinish: () => finished.next() };
     }
 }
 exports.LogTimings = LogTimings;

dist/src/flow-control/restart-process.js

@@ -50,7 +50,7 @@ "use strict";
         // explicitly telling the subscriber that a restart is needed
-        failure.pipe((0, operators_1.delay)(this.delay, this.scheduler), (0, operators_1.mapTo)(true)), 
+        failure.pipe((0, operators_1.delay)(this.delay, this.scheduler), (0, operators_1.map)(() => true)), 
         // Skip the first N emissions (as these would be duplicates of the above),
         // meaning it will be empty because of success, or failed all N times,
         // and no more restarts should be attempted.
-        failure.pipe((0, operators_1.skip)(this.tries), (0, operators_1.mapTo)(false), (0, operators_1.defaultIfEmpty)(false))).subscribe((restart) => {
+        failure.pipe((0, operators_1.skip)(this.tries), (0, operators_1.map)(() => false), (0, operators_1.defaultIfEmpty)(false))).subscribe((restart) => {
             const command = commands[index];
@@ -57,0 +57,0 @@ if (restart) {

dist/src/get-spawn-opts.d.ts

@@ -19,3 +19,3 @@ /// <reference types="node" />
      */
-    process?: Pick<NodeJS.Process, "cwd" | "env" | "platform"> | undefined;
+    process?: Pick<NodeJS.Process, "platform" | "cwd" | "env"> | undefined;
     /**
@@ -22,0 +22,0 @@ * A custom working directory to spawn processes in.

package.json

 {
   "name": "concurrently",
-  "version": "8.2.0",
+  "version": "8.2.1",
   "description": "Run commands concurrently",
@@ -52,29 +52,29 @@ "main": "index.js",
     "@hirez_io/observer-spy": "^2.2.0",
-    "@swc/core": "^1.3.62",
-    "@swc/jest": "^0.2.26",
-    "@types/jest": "^29.5.2",
-    "@types/lodash": "^4.14.195",
-    "@types/node": "^14.18.48",
+    "@swc/core": "^1.3.78",
+    "@swc/jest": "^0.2.29",
+    "@types/jest": "^29.5.3",
+    "@types/lodash": "^4.14.197",
+    "@types/node": "^14.18.54",
     "@types/shell-quote": "^1.7.1",
     "@types/supports-color": "^8.1.1",
     "@types/yargs": "^17.0.24",
-    "@typescript-eslint/eslint-plugin": "^5.59.9",
-    "@typescript-eslint/parser": "^5.59.9",
+    "@typescript-eslint/eslint-plugin": "^6.4.1",
+    "@typescript-eslint/parser": "^6.4.1",
     "coveralls-next": "^4.2.0",
     "ctrlc-wrapper": "^0.0.4",
-    "esbuild": "~0.17.19",
-    "eslint": "^8.42.0",
-    "eslint-config-prettier": "^8.8.0",
-    "eslint-plugin-import": "^2.27.5",
-    "eslint-plugin-jest": "^27.2.1",
-    "eslint-plugin-prettier": "^4.2.1",
+    "esbuild": "~0.19.2",
+    "eslint": "^8.47.0",
+    "eslint-config-prettier": "^9.0.0",
+    "eslint-plugin-import": "^2.28.1",
+    "eslint-plugin-jest": "^27.2.3",
+    "eslint-plugin-prettier": "^5.0.0",
     "eslint-plugin-simple-import-sort": "^10.0.0",
     "husky": "^8.0.3",
-    "jest": "^29.5.0",
+    "jest": "^29.6.3",
     "jest-create-mock-instance": "^2.0.0",
-    "lint-staged": "^13.2.2",
-    "prettier": "^2.8.8",
+    "lint-staged": "^13.3.0",
+    "prettier": "^3.0.2",
     "safe-publish-latest": "^2.0.0",
     "string-argv": "^0.3.2",
-    "typescript": "~5.1.3"
+    "typescript": "~5.1.6"
   },
@@ -81,0 +81,0 @@ "files": [

README.md

@@ -379,3 +379,3 @@ # concurrently
     cwd: path.resolve(__dirname, 'scripts'),
-  }
+  },
 );
@@ -382,0 +382,0 @@ result.then(success, failure);

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

120999

increased by0.31%

Lines of code

2508

increased by0.36%

No dependency changes