1 files changed, 117 insertions, 0 deletions
diff --git a/node_modules/concurrently/dist/src/command.js b/node_modules/concurrently/dist/src/command.js
new file mode 100644
index 0000000..e30bbb9
--- /dev/null
+++ b/node_modules/concurrently/dist/src/command.js
@@ -0,0 +1,117 @@
+"use strict";
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    var desc = Object.getOwnPropertyDescriptor(m, k);
+    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+      desc = { enumerable: true, get: function() { return m[k]; } };
+    }
+    Object.defineProperty(o, k2, desc);
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
+    Object.defineProperty(o, "default", { enumerable: true, value: v });
+}) : function(o, v) {
+    o["default"] = v;
+});
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    __setModuleDefault(result, mod);
+    return result;
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.Command = void 0;
+const Rx = __importStar(require("rxjs"));
+class Command {
+    /** @deprecated */
+    get killable() {
+        return Command.canKill(this);
+    }
+    constructor({ index, name, command, prefixColor, env, cwd }, spawnOpts, spawn, killProcess) {
+        this.close = new Rx.Subject();
+        this.error = new Rx.Subject();
+        this.stdout = new Rx.Subject();
+        this.stderr = new Rx.Subject();
+        this.timer = new Rx.Subject();
+        this.killed = false;
+        this.exited = false;
+        this.index = index;
+        this.name = name;
+        this.command = command;
+        this.prefixColor = prefixColor;
+        this.env = env || {};
+        this.cwd = cwd;
+        this.killProcess = killProcess;
+        this.spawn = spawn;
+        this.spawnOpts = spawnOpts;
+    }
+    /**
+     * Starts this command, piping output, error and close events onto the corresponding observables.
+     */
+    start() {
+        const child = this.spawn(this.command, this.spawnOpts);
+        this.process = child;
+        this.pid = child.pid;
+        const startDate = new Date(Date.now());
+        const highResStartTime = process.hrtime();
+        this.timer.next({ startDate });
+        Rx.fromEvent(child, 'error').subscribe((event) => {
+            this.process = undefined;
+            const endDate = new Date(Date.now());
+            this.timer.next({ startDate, endDate });
+            this.error.next(event);
+        });
+        Rx.fromEvent(child, 'close')
+            .pipe(Rx.map((event) => event))
+            .subscribe(([exitCode, signal]) => {
+            this.process = undefined;
+            this.exited = true;
+            const endDate = new Date(Date.now());
+            this.timer.next({ startDate, endDate });
+            const [durationSeconds, durationNanoSeconds] = process.hrtime(highResStartTime);
+            this.close.next({
+                command: this,
+                index: this.index,
+                exitCode: exitCode ?? String(signal),
+                killed: this.killed,
+                timings: {
+                    startDate,
+                    endDate,
+                    durationSeconds: durationSeconds + durationNanoSeconds / 1e9,
+                },
+            });
+        });
+        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;
+    }
+    /**
+     * Kills this command, optionally specifying a signal to send to it.
+     */
+    kill(code) {
+        if (Command.canKill(this)) {
+            this.killed = true;
+            this.killProcess(this.pid, code);
+        }
+    }
+    /**
+     * Detects whether a command can be killed.
+     *
+     * Also works as a type guard on the input `command`.
+     */
+    static canKill(command) {
+        return !!command.pid && !!command.process;
+    }
+}
+exports.Command = Command;
+/**
+ * Pipes all events emitted by `stream` into `subject`.
+ */
+function pipeTo(stream, subject) {
+    stream.subscribe((event) => subject.next(event));
+}