github/meteor
1
1
Fork 0
mirror of https://github.com/meteor/meteor.git synced 2026-05-02 03:01:46 -04:00
Code Issues Packages Projects Releases Wiki Activity

Allow specifying a destination option for execFileSync/Async

Browse Source 
If specified, instead of capturing the output, the child process stdout
will be piped to the destination stream.

Although the standard spawn stdio option lets you pass in streams,
these have to be connected to an open file descriptor. The destination
option allows you to use any Writable, so it can be used with a
Transform for instance.
This commit is contained in:
Martijn Walraven
2015-08-24 10:47:22 +02:00
parent df708d7309
commit b2c5ff4d5a
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
tools/utils/processes.js
View File

@@ -23,6 +23,8 @@ import child_process from 'child_process';
* @param {Array|String} [options.stdio] Child's stdio configuration.
* (Default: 'pipe') Specifying anything else than 'pipe' will disallow
* capture.
* @param {Writable} [options.destination] If specified, instead of capturing
* the output, the child process stdout will be piped to the destination stream.
* @param {String} [options.waitForClose] Whether to wait for the child process
* streams to close or to resolve the promise when the child process exits.
* @returns {String} The stdout from the command
@@ -44,6 +46,8 @@ export function execFileSync(command, args, options) {
* @param {Array|String} [options.stdio] Child's stdio configuration.
* (Default: 'pipe') Specifying anything else than 'pipe' will disallow
* capture.
* @param {Writable} [options.destination] If specified, instead of capturing
* the output, the child process stdout will be piped to the destination stream.
* @param {String} [options.waitForClose] Whether to wait for the child process
* streams to close or to resolve the promise when the child process exits.
* @returns {Promise<String>}
@@ -71,10 +75,14 @@ export function execFileAsync(command, args,
let capturedStdout = '';
if (child.stdout) {
child.stdout.setEncoding('utf8');
child.stdout.on('data', (data) => {
capturedStdout += data;
});
if (options.destination) {
child.stdout.pipe(options.destination);
} else {
child.stdout.setEncoding('utf8');
child.stdout.on('data', (data) => {
capturedStdout += data;
});
}
}
let capturedStderr = '';