spawn-to-readstream

Description

Make child process spawn behave like a read stream (buffer the error, don't emit end if error emitted).

Installation

1npm install spawn-to-readstream

Examples

1var toReadStream = require('spawn-to-readstream'),
2    spawn        = require('child_process').spawn;
3
4toReadStream(spawn('ls', ['-lah'])).on('error', function(err) {
5  throw err;
6}).on('end', function() {
7  console.log('~~~ DONE ~~~');
8}).on('data', function(data) {
9  console.log('ls data :::', data.toString());
10});

Limiting the output of the steam

1var toReadStream = require('../index'),
2    spawn        = require('child_process').spawn,
3    limit, buf;
4
5buf   = 0;
6limit = 100 * 1024; // 100 Kb
7
8// Note that it's a 'soft' limit, meaning the data you
9// receive might be > 100 Kb, because the child process
10// was stopped after receiving more than <LIMIT> bytes
11toReadStream(spawn('cat', ['/dev/urandom']), limit)
12  .on('error', function(err) {
13    throw err;
14  }).on('end', function(isLimited) {
15    console.log('done, ' + buf + ' bytes received');
16    if (isLimited) {
17      console.log('child process was cut');
18    }
19  }).on('data', function(data) {
20    buf += data.length;
21  });

Tests

1npm test

License

MIT