Suppose I have created a transform stream called Parser which can be written to like a normal stream but is read from as an object stream. I am using the readable event for the code that uses this transform stream:
var parser = new Parser();
parser.on('readable', function () {
var data = parser.read();
console.log(data);
});
In this event handler, must I repeatedly call parser.read()? Or, will readable fire on its own for every single object being pushed from my transform stream?
According to the node docs, "Once the internal buffer is drained, a readable event will fire again when more data is available," so if you call read() just once and there's still more data to be read, you'll have to remember to read() some more later on.
You could call read() in a while loop (inside your 'readable' event handler) until it returns null, then wait for the next 'readable' event.
If you don't specify a size you only need to call it once per event fire. Readable will fire on its own each time there is more data.
You then have readable.on('end', ... that will allow you to know when no more data is available.
