Add --group option

This option makes it so that the output is displayed as if the commands were run sequentially.

bin/concurrently.js

@@ -55,6 +55,10 @@ const args = yargs
             describe: 'Disables colors from logging',
             type: 'boolean'
         },
+        'group': {
+            describe: 'Order the output as if the commands were run sequentially.',
+            type: 'boolean'
+        },
 
         // Kill others
         'k': {
@@ -133,7 +137,7 @@ const args = yargs
                 'Can be either the index or the name of the process.'
         }
     })
-    .group(['m', 'n', 'name-separator', 'raw', 's', 'no-color'], 'General')
+    .group(['m', 'n', 'name-separator', 'raw', 's', 'no-color', 'group'], 'General')
     .group(['p', 'c', 'l', 't'], 'Prefix styling')
     .group(['i', 'default-input-target'], 'Input handling')
     .group(['k', 'kill-others-on-fail'], 'Killing other processes')
@@ -167,7 +171,8 @@ concurrently(args._.map((command, index) => {
     restartDelay: args.restartAfter,
     restartTries: args.restartTries,
     successCondition: args.success,
-    timestampFormat: args.timestampFormat
+    timestampFormat: args.timestampFormat,
+    group: args.group
 }).then(
     () => process.exit(0),
     () => process.exit(1)

index.js

@@ -11,7 +11,6 @@ const Logger = require('./src/logger');
 
 module.exports = (commands, options = {}) => {
     const logger = new Logger({
-        outputStream: options.outputStream || process.stdout,
         prefixFormat: options.prefix,
         prefixLength: options.prefixLength,
         raw: options.raw,
@@ -23,6 +22,9 @@ module.exports = (commands, options = {}) => {
         raw: options.raw,
         successCondition: options.successCondition,
         cwd: options.cwd,
+        logger,
+        outputStream: options.outputStream || process.stdout,
+        group: options.group,
         controllers: [
             new LogError({ logger }),
             new LogOutput({ logger }),

src/command.js

@@ -19,6 +19,7 @@ module.exports = class Command {
         this.close = new Rx.Subject();
         this.stdout = new Rx.Subject();
         this.stderr = new Rx.Subject();
+        this.exited = false;
     }
 
     start() {
@@ -32,6 +33,7 @@ module.exports = class Command {
         });
         Rx.fromEvent(child, 'close').subscribe(([exitCode, signal]) => {
             this.process = undefined;
+            this.exited = true;
             this.close.next({
                 command: {
                     command: this.command,

src/concurrently.js

@@ -11,6 +11,7 @@ const CompletionListener = require('./completion-listener');
 
 const getSpawnOpts = require('./get-spawn-opts');
 const Command = require('./command');
+const OutputWriter = require('./output-writer');
 
 const defaults = {
     spawn,
@@ -60,6 +61,15 @@ module.exports = (commands, options) => {
         maybeRunMore(commandsLeft);
     }
 
+    if (options.logger) {
+        const outputWriter = new OutputWriter({
+            outputStream: options.outputStream,
+            group: options.group,
+            commands,
+        });
+        options.logger.observable.subscribe(({command, text}) => outputWriter.write(command, text));
+    }
+
     return new CompletionListener({ successCondition: options.successCondition }).listen(commands);
 };
 

src/defaults.js

@@ -18,6 +18,8 @@ module.exports = {
     // How many bytes we'll show on the command prefix
     prefixLength: 10,
     raw: false,
+    // Whether to display output ordered as if the commands were sequential
+    group: false,
     // Number of attempts of restarting a process, if it exits with non-0 code
     restartTries: 0,
     // How many milliseconds concurrently should wait before restarting a process.

src/logger.js

@@ -1,16 +1,19 @@
 const chalk = require('chalk');
 const _ = require('lodash');
 const formatDate = require('date-fns/format');
+const Rx = require('rxjs');
 
 const defaults = require('./defaults');
+/** @typedef {import('./command.js')} Command */
 
 module.exports = class Logger {
-    constructor({ outputStream, prefixFormat, prefixLength, raw, timestampFormat }) {
+    constructor({ prefixFormat, prefixLength, raw, timestampFormat }) {
         this.raw = raw;
-        this.outputStream = outputStream;
         this.prefixFormat = prefixFormat;
         this.prefixLength = prefixLength || defaults.prefixLength;
         this.timestampFormat = timestampFormat || defaults.timestampFormat;
+        /** @type {Rx.Subject<{ command: Command, text: string }>} */
+        this.observable = new Rx.Subject();
     }
 
     shortenText(text) {
@@ -76,20 +79,20 @@ module.exports = class Logger {
 
     logCommandText(text, command) {
         const prefix = this.colorText(command, this.getPrefix(command));
-        return this.log(prefix + (prefix ? ' ' : ''), text);
+        return this.log(prefix + (prefix ? ' ' : ''), text, command);
     }
 
     logGlobalEvent(text) {
         if (this.raw) {
             return;
         }
 
-        this.log(chalk.gray.dim('-->') + ' ', chalk.gray.dim(text) + '\n');
+        this.log(chalk.gray.dim('-->') + ' ', chalk.gray.dim(text) + '\n', null);
     }
 
-    log(prefix, text) {
+    log(prefix, text, command) {
         if (this.raw) {
-            return this.outputStream.write(text);
+            return this.emit(command, text);
         }
 
         // #70 - replace some ANSI code that would impact clearing lines
@@ -105,10 +108,18 @@ module.exports = class Logger {
         });
 
         if (!this.lastChar || this.lastChar === '\n') {
-            this.outputStream.write(prefix);
+            this.emit(command, prefix);
         }
 
         this.lastChar = text[text.length - 1];
-        this.outputStream.write(lines.join('\n'));
+        this.emit(command, lines.join('\n'));
+    }
+
+    /**
+     * @param {Command} command 
+     * @param {string} text 
+     */
+    emit(command, text) {
+        this.observable.next({ command, text });
     }
 };