Add --group option

bin/concurrently.js

@@ -62,6 +62,10 @@ const args = yargs
             default: defaults.hide,
             type: 'string'
         },
+        'group': {
+            describe: 'Order the output as if the commands were run sequentially.',
+            type: 'boolean'
+        },
 
         // Kill others
         'k': {
@@ -142,7 +146,7 @@ const args = yargs
                 'Can be either the index or the name of the process.'
         }
     })
-    .group(['m', 'n', 'name-separator', 'raw', 's', 'no-color', 'hide'], 'General')
+    .group(['m', 'n', 'name-separator', 'raw', 's', 'no-color', 'hide', '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')
@@ -165,6 +169,7 @@ concurrently(args._.map((command, index) => ({
     maxProcesses: args.maxProcesses,
     raw: args.raw,
     hide: args.hide.split(','),
+    group: args.group,
     prefix: args.prefix,
     prefixColors: args.prefixColors.split(','),
     prefixLength: args.prefixLength,

index.js

@@ -12,7 +12,6 @@ const Logger = require('./src/logger');
 module.exports = exports = (commands, options = {}) => {
     const logger = new Logger({
         hide: options.hide,
-        outputStream: options.outputStream || process.stdout,
         prefixFormat: options.prefix,
         prefixLength: options.prefixLength,
         raw: options.raw,
@@ -24,6 +23,9 @@ module.exports = 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

@@ -20,6 +20,7 @@ module.exports = class Command {
         this.close = new Rx.Subject();
         this.stdout = new Rx.Subject();
         this.stderr = new Rx.Subject();
+        this.exited = false;
     }
 
     start() {
@@ -33,6 +34,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,
@@ -73,6 +74,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)
         .finally(() => {

src/defaults.js

@@ -20,6 +20,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,20 +1,21 @@
 const chalk = require('chalk');
 const _ = require('lodash');
 const formatDate = require('date-fns/format');
+const Rx = require('rxjs');
 
 const defaults = require('./defaults');
 
 module.exports = class Logger {
-    constructor({ hide, outputStream, prefixFormat, prefixLength, raw, timestampFormat }) {
+    constructor({ hide, prefixFormat, prefixLength, raw, timestampFormat }) {
         // To avoid empty strings from hiding the output of commands that don't have a name,
         // keep in the list of commands to hide only strings with some length.
         // This might happen through the CLI when no `--hide` argument is specified, for example.
         this.hide = _.castArray(hide).filter(name => name || name === 0).map(String);
         this.raw = raw;
-        this.outputStream = outputStream;
         this.prefixFormat = prefixFormat;
         this.prefixLength = prefixLength || defaults.prefixLength;
         this.timestampFormat = timestampFormat || defaults.timestampFormat;
+        this.observable = new Rx.Subject();
     }
 
     shortenText(text) {
@@ -85,20 +86,20 @@ module.exports = class Logger {
         }
 
         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.reset('-->') + ' ', chalk.reset(text) + '\n');
+        this.log(chalk.reset('-->') + ' ', chalk.reset(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
@@ -114,10 +115,14 @@ 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'));
+    }
+
+    emit(command, text) {
+        this.observable.next({ command, text });
     }
 };