diff options
| author | Pinapelz <yukais@pinapelz.com> | 2025-06-29 11:49:28 -0700 |
|---|---|---|
| committer | Pinapelz <yukais@pinapelz.com> | 2025-06-29 11:49:28 -0700 |
| commit | d55b767039605256c736166a942a9138e3eacfd7 (patch) | |
| tree | 947063b634c50d438a794325f13275e134aa5993 /node_modules/concurrently/dist/src/flow-control/input-handler.js | |
| parent | 864ce67d89c77d8ef9c3361f80d619853abcf91c (diff) | |
remove dev node_modules (oops)
Diffstat (limited to 'node_modules/concurrently/dist/src/flow-control/input-handler.js')
| -rw-r--r-- | node_modules/concurrently/dist/src/flow-control/input-handler.js | 90 |
1 files changed, 0 insertions, 90 deletions
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; |
