Как закрыть поток, который не имеет больше данных для отправки в node.js?

Question

Я использую node.js и считываю ввод из последовательного порта, открывая файл/dev/tty, я отправляю команду и читаю результат команды, и я хочу закрыть поток после того, как прочитал и проанализировал все данные. Я знаю, что я закончил считывание данных маркером данных и их окончанием. Я нахожу, что как только я закрыл поток, моя программа не закончится.

Ниже приведен пример того, что я вижу, но использует/dev/random для медленного генерации данных (если ваша система не делает много). То, что я нахожу, это то, что процесс завершится, как только устройство генерирует данные после поток был закрыт.

var util = require('util'), 
    PassThrough = require('stream').PassThrough, 
    fs = require('fs'); 

// If the system is not doing enough to fill the entropy pool 
// /dev/random will not return much data. Feed the entropy pool with : 
// ssh <host> 'cat /dev/urandom' > /dev/urandom 
var readStream = fs.createReadStream('/dev/random'); 
var pt = new PassThrough(); 

pt.on('data', function (data) { 
    console.log(data) 
    console.log('closing'); 
    readStream.close(); //expect the process to terminate immediately 
}); 

readStream.pipe(pt); 

Update: 1

Я вернулся на этот вопрос и есть еще один образец, это один раз использует и PTY легко воспроизводится в РЕПЛ узле. Войдите в систему на 2 терминалах и используйте pty терминала, в котором вы не используете узел, в следующем вызове createReadStream.

var fs = require('fs'); 
var rs = fs.createReadStream('/dev/pts/1'); // a pty that is allocated in another terminal by my user 
//wait just a second, don't copy and paste everything at once 
process.exit(0); 

В этот момент узел будет просто висеть и не выходить. Это на 10.28.

Answer 1

Вы закрываете поток /dev/random, но у вас все еще есть слушатель для события 'data' на проходе, который будет поддерживать приложение до тех пор, пока проход не будет закрыт.

Я предполагаю, что из потока чтения есть некоторые буферизованные данные, и до тех пор, пока это не будет сброшено, сквозной проход не будет закрыт. Но это всего лишь предположение.

Чтобы получить желаемое поведение, вы можете удалить слушатель события на проходной, как это:

pt.on('data', function (data) { 
    console.log(data) 
    console.log('closing'); 

    pt.removeAllListeners('data'); 
    readStream.close(); 
}); 

Answer 2

Вместо использование

readStream.close(), 

попробуйте использовать

readStream.pause(). 

Но , если вы используете новейшую версию узла, оберните поток чтения с помощью объекта, созданного с stream модуль по Айзекс, как это:

var Readable = require('stream').Readable; 
var myReader = new Readable().wrap(readStream); 

и использовать MyReader вместо ReadStream после этого.

Удачи! Скажите, если это сработает.