node.js - чтение дочернего процесса stdout 100 байт за один раз

Question

Я порождаю ребенка, который производит много данных (я использую здесь 'ls -lR /' здесь в качестве примера). Я хочу асинхронно читать stdout ребенка по 100 байт за раз.

Так что я хочу сделать: get100(), а затем (process100) .then (get100) .then (process100) .then (...

По какой-то причине этот код только петли. 3 раза и я перестану получать читаемым события. Я не могу понять, почему?

var Promise = require('bluebird'); 
var spawn = require("child_process").spawn; 

var exec = spawn("ls", [ "-lR", "/"]); 

var get100 = function() { 
    return new Promise(function(resolve, reject) { 
     var tryTransfer = function() { 
      var block = exec.stdout.read(100); 
      if (block) { 
      console.log("Got 100 Bytes"); 
      exec.stdout.removeAllListeners('readable'); 
      resolve(); 
      } else console.log("Read Failed - not enough bytes?"); 
     }; 
     exec.stdout.on('readable', tryTransfer); 
    }); 
}; 

var forEver = Promise.method(function(action) { 
    return action().then(forEver.bind(null, action)); 
}); 

forEver(
    function() { return get100(); } 
) 

Answer 1

Использование event-stream, вы можете испускают данные 100 байт из порожденного процесса до тех пор, пока данные для чтения (потоки async):

var es = require('event-stream'); 
var spawn = require("child_process").spawn; 

var exec = spawn("ls", ["-lR", "/"]); 

var stream = es.readable(function (count, next) { 
    // read 100 bytes 
    while (block = exec.stdout.read(100)) { 
     // if you have tons of data, it's not a good idea to log here 
     // console.log("Got 100 Bytes"); 
     // emit the block 
     this.emit('data', block.toString()); // block is a buffer (bytes array), you may need toString() or not 
    } 

    // no more data left to read 
    this.emit('end'); 
    next(); 
}).on('data', function(data) { 
    // data is the 100 bytes block, do what you want here 

    // the stream is pausable and resumable at will 
    stream.pause(); 
    doStuff(data, function() { 
     stream.resume(); 
    }); 
});