читаемой записи потока не возвращает нуль

Question

Док для readableStream.read(size) говорит,

если размер байты не доступны, то он будет возвращать нуль.

Чтобы проверить это я сделал:

// in test.js 
process.stdin.on('readable', function(){ 
    var d = this.read(30); 
    if (d) console.log(d.toString()); 
}); 

$ (echo abc; sleep 1; echo def; sleep 1; echo ghi) | node test.js 

Выход был следующим:

abc 
def 
ghi 

Я ожидал, что код для печати null, как size(30) было больше, чем записанных байтов. Почему он не печатает null?

Согласно комментариям @ hexacyanide, я переписал код, как показано ниже, и снова запускали тест: выход

process.stdin.on('readable', function() { 
    var d = this.read(300); 
    if (d === null) { 
    console.log("NULL") 
    } else { 
    console.log(d.toString()); 
    } 
}); 

process.stdin.on('end', function() { 
    console.log('END EVENT') 
}); 

Тест:

NULL 
NULL 
NULL 
abc 
def 
ghi 

END EVENT 

теперь я могу понять, выход до 3 NULL's.
После этого у меня есть несколько вопросов, основанных на выходе:

1. Почему я получаю abc\ndef\nghi как выход для моего первого теста? Я спрашиваю об этом, потому что даже после нажатия abcdefghi на поток длина его буфера равна 9. Поэтому, если я прочитал какое-либо время, операция чтения должна вернуть null. Разумеется, я установил размер чтения в 300.
2. Как поток знает, что я выполнил все мои нажатия?

Answer 1

При попытке воспроизвести вашу проблему я предположил, что вы уже возобновили поток process.stdin, который по умолчанию приостановлен. Позже я узнал, что, покидая этот бит, я получил непреднамеренный вывод, который вы получали. Это то, что документация NodeJS гласит:

поток стандартного ввода паузы по умолчанию, поэтому необходимо позвонить process.stdin.resume() читать из него.

Перед добавлением readable слушателя, я просто использовал resume() на поток и получил предполагаемую продукцию.

Я не знаю, если я правильно, но в вашем случае, я бы предположить, что readable стреляет каждый раз echo запускается, и read() не читает ничего в тех случаях, но когда stdin закрыт, read() просто читает все.Вот мой тестовый код и результаты:

process.stdin.on('readable', function() { 
    console.log('fire'); 
    console.log(process.stdin.read(300)); 
}).on('end', function(){ 
    console.log("END EVENT") 
}); 

Я побежал этот код так: (echo abc; sleep 1; echo def; sleep 1; echo ghi) | node test.js и получил следующие результаты:

fire 
null 
fire 
null 
fire 
null 
fire 
<Buffer 61 62 63 0a 64 65 66 0a 67 68 69 0a> 
END EVENT 

При тестировании после возобновления stdin потока, readable пожаров в четыре раза, и read(300) правильно возвращает null.