Method handle

lib/flow-control/input-handler.ts:43–94

(commands: Command[])

    }

    handle(commands: Command[]): {
        commands: Command[];
        onFinish?: () => void | undefined;
    } {
        const { inputStream } = this;
        if (!inputStream) {
            return { commands };
        }

        const commandsMap = new Map<string, Command>();
        for (const command of commands) {
            commandsMap.set(command.index.toString(), command);
            commandsMap.set(command.name, command);
        }

        Rx.fromEvent(inputStream, 'data')
            .pipe(map((data) => String(data)))
            .subscribe((data) => {
                const dataParts = data.split(/:(.+)/s);
                let target = dataParts[0];
                let command = commandsMap.get(target);
                let input: string;

                if (dataParts.length > 1 && command) {
                    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?.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();
                }
            },
        };
    }
}