diff options
Diffstat (limited to 'node_modules/concurrently/dist/src/flow-control')
18 files changed, 0 insertions, 566 deletions
diff --git a/node_modules/concurrently/dist/src/flow-control/flow-controller.d.ts b/node_modules/concurrently/dist/src/flow-control/flow-controller.d.ts deleted file mode 100644 index b518aad..0000000 --- a/node_modules/concurrently/dist/src/flow-control/flow-controller.d.ts +++ /dev/null @@ -1,13 +0,0 @@ -import { Command } from '../command'; -/** - * Interface for a class that controls and/or watches the behavior of commands. - * - * This may include logging their output, creating interactions between them, or changing when they - * actually finish. - */ -export interface FlowController { - handle(commands: Command[]): { - commands: Command[]; - onFinish?: () => void; - }; -} diff --git a/node_modules/concurrently/dist/src/flow-control/flow-controller.js b/node_modules/concurrently/dist/src/flow-control/flow-controller.js deleted file mode 100644 index c8ad2e5..0000000 --- a/node_modules/concurrently/dist/src/flow-control/flow-controller.js +++ /dev/null @@ -1,2 +0,0 @@ -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); diff --git a/node_modules/concurrently/dist/src/flow-control/input-handler.d.ts b/node_modules/concurrently/dist/src/flow-control/input-handler.d.ts deleted file mode 100644 index 3a7ee5a..0000000 --- a/node_modules/concurrently/dist/src/flow-control/input-handler.d.ts +++ /dev/null @@ -1,30 +0,0 @@ -/// <reference types="node" /> -import { Readable } from 'stream'; -import { Command, CommandIdentifier } from '../command'; -import { Logger } from '../logger'; -import { FlowController } from './flow-controller'; -/** - * Sends input from concurrently through to commands. - * - * Input can start with a command identifier, in which case it will be sent to that specific command. - * For instance, `0:bla` will send `bla` to command at index `0`, and `server:stop` will send `stop` - * to command with name `server`. - * - * If the input doesn't start with a command identifier, it is then always sent to the default target. - */ -export declare class InputHandler implements FlowController { - private readonly logger; - private readonly defaultInputTarget; - private readonly inputStream?; - private readonly pauseInputStreamOnFinish; - constructor({ defaultInputTarget, inputStream, pauseInputStreamOnFinish, logger, }: { - inputStream?: Readable; - logger: Logger; - defaultInputTarget?: CommandIdentifier; - pauseInputStreamOnFinish?: boolean; - }); - handle(commands: Command[]): { - commands: Command[]; - onFinish?: () => void | undefined; - }; -} diff --git a/node_modules/concurrently/dist/src/flow-control/input-handler.js b/node_modules/concurrently/dist/src/flow-control/input-handler.js deleted file mode 100644 index 76c552f..0000000 --- a/node_modules/concurrently/dist/src/flow-control/input-handler.js +++ /dev/null @@ -1,90 +0,0 @@ -"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.InputHandler = void 0; -const Rx = __importStar(require("rxjs")); -const operators_1 = require("rxjs/operators"); -const defaults = __importStar(require("../defaults")); -/** - * Sends input from concurrently through to commands. - * - * Input can start with a command identifier, in which case it will be sent to that specific command. - * For instance, `0:bla` will send `bla` to command at index `0`, and `server:stop` will send `stop` - * to command with name `server`. - * - * If the input doesn't start with a command identifier, it is then always sent to the default target. - */ -class InputHandler { - constructor({ defaultInputTarget, inputStream, pauseInputStreamOnFinish, logger, }) { - this.logger = logger; - this.defaultInputTarget = defaultInputTarget || defaults.defaultInputTarget; - this.inputStream = inputStream; - this.pauseInputStreamOnFinish = pauseInputStreamOnFinish !== false; - } - handle(commands) { - const { inputStream } = this; - if (!inputStream) { - return { commands }; - } - const commandsMap = new Map(); - for (const command of commands) { - commandsMap.set(command.index.toString(), command); - commandsMap.set(command.name, command); - } - Rx.fromEvent(inputStream, 'data') - .pipe((0, operators_1.map)((data) => String(data))) - .subscribe((data) => { - let command, input; - const dataParts = data.split(/:(.+)/s); - let target = dataParts[0]; - if (dataParts.length > 1 && (command = commandsMap.get(target))) { - input = dataParts[1]; - } - else { - // If `target` does not match a registered command, - // fallback to `defaultInputTarget` and forward the whole input data - target = this.defaultInputTarget.toString(); - command = commandsMap.get(target); - input = data; - } - if (command && command.stdin) { - command.stdin.write(input); - } - else { - this.logger.logGlobalEvent(`Unable to find command "${target}", or it has no stdin open\n`); - } - }); - return { - commands, - onFinish: () => { - if (this.pauseInputStreamOnFinish) { - // https://github.com/kimmobrunfeldt/concurrently/issues/252 - inputStream.pause(); - } - }, - }; - } -} -exports.InputHandler = InputHandler; diff --git a/node_modules/concurrently/dist/src/flow-control/kill-on-signal.d.ts b/node_modules/concurrently/dist/src/flow-control/kill-on-signal.d.ts deleted file mode 100644 index d706694..0000000 --- a/node_modules/concurrently/dist/src/flow-control/kill-on-signal.d.ts +++ /dev/null @@ -1,17 +0,0 @@ -/// <reference types="node" /> -import EventEmitter from 'events'; -import { Command } from '../command'; -import { FlowController } from './flow-controller'; -/** - * Watches the main concurrently process for signals and sends the same signal down to each spawned - * command. - */ -export declare class KillOnSignal implements FlowController { - private readonly process; - constructor({ process }: { - process: EventEmitter; - }); - handle(commands: Command[]): { - commands: Command[]; - }; -} diff --git a/node_modules/concurrently/dist/src/flow-control/kill-on-signal.js b/node_modules/concurrently/dist/src/flow-control/kill-on-signal.js deleted file mode 100644 index 716a9bf..0000000 --- a/node_modules/concurrently/dist/src/flow-control/kill-on-signal.js +++ /dev/null @@ -1,36 +0,0 @@ -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); -exports.KillOnSignal = void 0; -const operators_1 = require("rxjs/operators"); -/** - * Watches the main concurrently process for signals and sends the same signal down to each spawned - * command. - */ -class KillOnSignal { - constructor({ process }) { - this.process = process; - } - handle(commands) { - let caughtSignal; - ['SIGINT', 'SIGTERM', 'SIGHUP'].forEach((signal) => { - this.process.on(signal, () => { - caughtSignal = signal; - commands.forEach((command) => command.kill(signal)); - }); - }); - return { - commands: commands.map((command) => { - const closeStream = command.close.pipe((0, operators_1.map)((exitInfo) => { - const exitCode = caughtSignal === 'SIGINT' ? 0 : exitInfo.exitCode; - return { ...exitInfo, exitCode }; - })); - return new Proxy(command, { - get(target, prop) { - return prop === 'close' ? closeStream : target[prop]; - }, - }); - }), - }; - } -} -exports.KillOnSignal = KillOnSignal; diff --git a/node_modules/concurrently/dist/src/flow-control/kill-others.d.ts b/node_modules/concurrently/dist/src/flow-control/kill-others.d.ts deleted file mode 100644 index f10b7bb..0000000 --- a/node_modules/concurrently/dist/src/flow-control/kill-others.d.ts +++ /dev/null @@ -1,20 +0,0 @@ -import { Command } from '../command'; -import { Logger } from '../logger'; -import { FlowController } from './flow-controller'; -export type ProcessCloseCondition = 'failure' | 'success'; -/** - * Sends a SIGTERM signal to all commands when one of the commands exits with a matching condition. - */ -export declare class KillOthers implements FlowController { - private readonly logger; - private readonly conditions; - private readonly killSignal; - constructor({ logger, conditions, killSignal, }: { - logger: Logger; - conditions: ProcessCloseCondition | ProcessCloseCondition[]; - killSignal: string | undefined; - }); - handle(commands: Command[]): { - commands: Command[]; - }; -} diff --git a/node_modules/concurrently/dist/src/flow-control/kill-others.js b/node_modules/concurrently/dist/src/flow-control/kill-others.js deleted file mode 100644 index 1751677..0000000 --- a/node_modules/concurrently/dist/src/flow-control/kill-others.js +++ /dev/null @@ -1,35 +0,0 @@ -"use strict"; -var __importDefault = (this && this.__importDefault) || function (mod) { - return (mod && mod.__esModule) ? mod : { "default": mod }; -}; -Object.defineProperty(exports, "__esModule", { value: true }); -exports.KillOthers = void 0; -const lodash_1 = __importDefault(require("lodash")); -const operators_1 = require("rxjs/operators"); -const command_1 = require("../command"); -/** - * Sends a SIGTERM signal to all commands when one of the commands exits with a matching condition. - */ -class KillOthers { - constructor({ logger, conditions, killSignal, }) { - this.logger = logger; - this.conditions = lodash_1.default.castArray(conditions); - this.killSignal = killSignal; - } - handle(commands) { - const conditions = this.conditions.filter((condition) => condition === 'failure' || condition === 'success'); - if (!conditions.length) { - return { commands }; - } - const closeStates = commands.map((command) => command.close.pipe((0, operators_1.map)(({ exitCode }) => exitCode === 0 ? 'success' : 'failure'), (0, operators_1.filter)((state) => conditions.includes(state)))); - closeStates.forEach((closeState) => closeState.subscribe(() => { - const killableCommands = commands.filter((command) => command_1.Command.canKill(command)); - if (killableCommands.length) { - this.logger.logGlobalEvent(`Sending ${this.killSignal || 'SIGTERM'} to other processes..`); - killableCommands.forEach((command) => command.kill(this.killSignal)); - } - })); - return { commands }; - } -} -exports.KillOthers = KillOthers; diff --git a/node_modules/concurrently/dist/src/flow-control/log-error.d.ts b/node_modules/concurrently/dist/src/flow-control/log-error.d.ts deleted file mode 100644 index 8eac6dd..0000000 --- a/node_modules/concurrently/dist/src/flow-control/log-error.d.ts +++ /dev/null @@ -1,15 +0,0 @@ -import { Command } from '../command'; -import { Logger } from '../logger'; -import { FlowController } from './flow-controller'; -/** - * Logs when commands failed executing, e.g. due to the executable not existing in the system. - */ -export declare class LogError implements FlowController { - private readonly logger; - constructor({ logger }: { - logger: Logger; - }); - handle(commands: Command[]): { - commands: Command[]; - }; -} diff --git a/node_modules/concurrently/dist/src/flow-control/log-error.js b/node_modules/concurrently/dist/src/flow-control/log-error.js deleted file mode 100644 index 8fc7210..0000000 --- a/node_modules/concurrently/dist/src/flow-control/log-error.js +++ /dev/null @@ -1,20 +0,0 @@ -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); -exports.LogError = void 0; -/** - * Logs when commands failed executing, e.g. due to the executable not existing in the system. - */ -class LogError { - constructor({ logger }) { - this.logger = logger; - } - handle(commands) { - commands.forEach((command) => command.error.subscribe((event) => { - this.logger.logCommandEvent(`Error occurred when executing command: ${command.command}`, command); - const errorText = String(event instanceof Error ? event.stack || event : event); - this.logger.logCommandEvent(errorText, command); - })); - return { commands }; - } -} -exports.LogError = LogError; diff --git a/node_modules/concurrently/dist/src/flow-control/log-exit.d.ts b/node_modules/concurrently/dist/src/flow-control/log-exit.d.ts deleted file mode 100644 index 47b8718..0000000 --- a/node_modules/concurrently/dist/src/flow-control/log-exit.d.ts +++ /dev/null @@ -1,15 +0,0 @@ -import { Command } from '../command'; -import { Logger } from '../logger'; -import { FlowController } from './flow-controller'; -/** - * Logs the exit code/signal of commands. - */ -export declare class LogExit implements FlowController { - private readonly logger; - constructor({ logger }: { - logger: Logger; - }); - handle(commands: Command[]): { - commands: Command[]; - }; -} diff --git a/node_modules/concurrently/dist/src/flow-control/log-exit.js b/node_modules/concurrently/dist/src/flow-control/log-exit.js deleted file mode 100644 index 6fe396d..0000000 --- a/node_modules/concurrently/dist/src/flow-control/log-exit.js +++ /dev/null @@ -1,18 +0,0 @@ -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); -exports.LogExit = void 0; -/** - * Logs the exit code/signal of commands. - */ -class LogExit { - constructor({ logger }) { - this.logger = logger; - } - handle(commands) { - commands.forEach((command) => command.close.subscribe(({ exitCode }) => { - this.logger.logCommandEvent(`${command.command} exited with code ${exitCode}`, command); - })); - return { commands }; - } -} -exports.LogExit = LogExit; diff --git a/node_modules/concurrently/dist/src/flow-control/log-output.d.ts b/node_modules/concurrently/dist/src/flow-control/log-output.d.ts deleted file mode 100644 index 6c916de..0000000 --- a/node_modules/concurrently/dist/src/flow-control/log-output.d.ts +++ /dev/null @@ -1,15 +0,0 @@ -import { Command } from '../command'; -import { Logger } from '../logger'; -import { FlowController } from './flow-controller'; -/** - * Logs the stdout and stderr output of commands. - */ -export declare class LogOutput implements FlowController { - private readonly logger; - constructor({ logger }: { - logger: Logger; - }); - handle(commands: Command[]): { - commands: Command[]; - }; -} diff --git a/node_modules/concurrently/dist/src/flow-control/log-output.js b/node_modules/concurrently/dist/src/flow-control/log-output.js deleted file mode 100644 index 486a25b..0000000 --- a/node_modules/concurrently/dist/src/flow-control/log-output.js +++ /dev/null @@ -1,19 +0,0 @@ -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); -exports.LogOutput = void 0; -/** - * Logs the stdout and stderr output of commands. - */ -class LogOutput { - constructor({ logger }) { - this.logger = logger; - } - handle(commands) { - commands.forEach((command) => { - command.stdout.subscribe((text) => this.logger.logCommandText(text.toString(), command)); - command.stderr.subscribe((text) => this.logger.logCommandText(text.toString(), command)); - }); - return { commands }; - } -} -exports.LogOutput = LogOutput; diff --git a/node_modules/concurrently/dist/src/flow-control/log-timings.d.ts b/node_modules/concurrently/dist/src/flow-control/log-timings.d.ts deleted file mode 100644 index a847707..0000000 --- a/node_modules/concurrently/dist/src/flow-control/log-timings.d.ts +++ /dev/null @@ -1,31 +0,0 @@ -import { CloseEvent, Command } from '../command'; -import { Logger } from '../logger'; -import { FlowController } from './flow-controller'; -type TimingInfo = { - name: string; - duration: string; - 'exit code': string | number; - killed: boolean; - command: string; -}; -/** - * Logs timing information about commands as they start/stop and then a summary when all commands finish. - */ -export declare class LogTimings implements FlowController { - static mapCloseEventToTimingInfo({ command, timings, killed, exitCode, }: CloseEvent): TimingInfo; - private readonly logger?; - private readonly timestampFormat; - constructor({ logger, timestampFormat, }: { - logger?: Logger; - timestampFormat?: string; - }); - private printExitInfoTimingTable; - handle(commands: Command[]): { - commands: Command[]; - onFinish?: undefined; - } | { - commands: Command[]; - onFinish: () => void; - }; -} -export {}; diff --git a/node_modules/concurrently/dist/src/flow-control/log-timings.js b/node_modules/concurrently/dist/src/flow-control/log-timings.js deleted file mode 100644 index 9c8879d..0000000 --- a/node_modules/concurrently/dist/src/flow-control/log-timings.js +++ /dev/null @@ -1,92 +0,0 @@ -"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; -}; -var __importDefault = (this && this.__importDefault) || function (mod) { - return (mod && mod.__esModule) ? mod : { "default": mod }; -}; -Object.defineProperty(exports, "__esModule", { value: true }); -exports.LogTimings = void 0; -const assert = __importStar(require("assert")); -const format_1 = __importDefault(require("date-fns/format")); -const lodash_1 = __importDefault(require("lodash")); -const Rx = __importStar(require("rxjs")); -const operators_1 = require("rxjs/operators"); -const defaults = __importStar(require("../defaults")); -/** - * Logs timing information about commands as they start/stop and then a summary when all commands finish. - */ -class LogTimings { - static mapCloseEventToTimingInfo({ command, timings, killed, exitCode, }) { - const readableDurationMs = (timings.endDate.getTime() - timings.startDate.getTime()).toLocaleString(); - return { - name: command.name, - duration: readableDurationMs, - 'exit code': exitCode, - killed, - command: command.command, - }; - } - constructor({ logger, timestampFormat = defaults.timestampFormat, }) { - this.logger = logger; - this.timestampFormat = timestampFormat; - } - printExitInfoTimingTable(exitInfos) { - assert.ok(this.logger); - const exitInfoTable = (0, lodash_1.default)(exitInfos) - .sortBy(({ timings }) => timings.durationSeconds) - .reverse() - .map(LogTimings.mapCloseEventToTimingInfo) - .value(); - this.logger.logGlobalEvent('Timings:'); - this.logger.logTable(exitInfoTable); - return exitInfos; - } - handle(commands) { - const { logger } = this; - if (!logger) { - return { commands }; - } - // individual process timings - commands.forEach((command) => { - command.timer.subscribe(({ startDate, endDate }) => { - if (!endDate) { - const formattedStartDate = (0, format_1.default)(startDate, this.timestampFormat); - logger.logCommandEvent(`${command.command} started at ${formattedStartDate}`, command); - } - else { - const durationMs = endDate.getTime() - startDate.getTime(); - const formattedEndDate = (0, format_1.default)(endDate, this.timestampFormat); - logger.logCommandEvent(`${command.command} stopped at ${formattedEndDate} after ${durationMs.toLocaleString()}ms`, command); - } - }); - }); - // overall summary timings - const closeStreams = commands.map((command) => command.close); - 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; diff --git a/node_modules/concurrently/dist/src/flow-control/restart-process.d.ts b/node_modules/concurrently/dist/src/flow-control/restart-process.d.ts deleted file mode 100644 index 735d8d5..0000000 --- a/node_modules/concurrently/dist/src/flow-control/restart-process.d.ts +++ /dev/null @@ -1,22 +0,0 @@ -import * as Rx from 'rxjs'; -import { Command } from '../command'; -import { Logger } from '../logger'; -import { FlowController } from './flow-controller'; -/** - * Restarts commands that fail up to a defined number of times. - */ -export declare class RestartProcess implements FlowController { - private readonly logger; - private readonly scheduler?; - readonly delay: number; - readonly tries: number; - constructor({ delay, tries, logger, scheduler, }: { - delay?: number; - tries?: number; - logger: Logger; - scheduler?: Rx.SchedulerLike; - }); - handle(commands: Command[]): { - commands: Command[]; - }; -} diff --git a/node_modules/concurrently/dist/src/flow-control/restart-process.js b/node_modules/concurrently/dist/src/flow-control/restart-process.js deleted file mode 100644 index 79131ce..0000000 --- a/node_modules/concurrently/dist/src/flow-control/restart-process.js +++ /dev/null @@ -1,76 +0,0 @@ -"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.RestartProcess = void 0; -const Rx = __importStar(require("rxjs")); -const operators_1 = require("rxjs/operators"); -const defaults = __importStar(require("../defaults")); -/** - * Restarts commands that fail up to a defined number of times. - */ -class RestartProcess { - constructor({ delay, tries, logger, scheduler, }) { - this.logger = logger; - this.delay = delay != null ? +delay : defaults.restartDelay; - this.tries = tries != null ? +tries : defaults.restartTries; - this.tries = this.tries < 0 ? Infinity : this.tries; - this.scheduler = scheduler; - } - handle(commands) { - if (this.tries === 0) { - return { commands }; - } - commands - .map((command) => command.close.pipe((0, operators_1.take)(this.tries), (0, operators_1.takeWhile)(({ exitCode }) => exitCode !== 0))) - .map((failure, index) => Rx.merge( - // Delay the emission (so that the restarts happen on time), - // explicitly telling the subscriber that a restart is needed - 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.map)(() => false), (0, operators_1.defaultIfEmpty)(false))).subscribe((restart) => { - const command = commands[index]; - if (restart) { - this.logger.logCommandEvent(`${command.command} restarted`, command); - command.start(); - } - })); - return { - commands: commands.map((command) => { - const closeStream = command.close.pipe((0, operators_1.filter)(({ exitCode }, emission) => { - // We let all success codes pass, and failures only after restarting won't happen again - return exitCode === 0 || emission >= this.tries; - })); - return new Proxy(command, { - get(target, prop) { - return prop === 'close' ? closeStream : target[prop]; - }, - }); - }), - }; - } -} -exports.RestartProcess = RestartProcess; |