CODEWITHSUNDEEP
node.jsnode.js-stream
Brad
Brad

Reputation: 163232

Must I repeatedly call readable.read() within a readable event handler?

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?

Upvotes: 6

Views: 288

Answers (2)

fmsf
fmsf

Reputation: 37137

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.

Upvotes: 1

mscdex
mscdex

Reputation: 106696

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.

Upvotes: 6

Related Questions