Hello,
You shouldn't be the one implementing .resume() .pause() and
emit('readble') or emit('data')
This is why streams have been rewritten.
The API for implementing a readable stream is to inherit from
stream.Readable and implement _write() and optionally _flush()
http://nodejs.org/api/stream.html#stream_api_for_stream_implementors
On Monday, 4 August 2014 14:46:42 UTC+2, manimal45 wrote:
>
> Hi, I'm unable to understand how exactly readablestream 'data' event works
> (I'm using node v0.11.13).
>
> I have this simple example :
>
> var util = require('util'),
> stream = require("stream");
>
> // A simple readable stream
> var R = function(){
> stream.Readable.call(this,{objectMode : true});
> this.index = 1;
> }
> // R inherits from Readable
> util.inherits(R, stream.Readable);
>
> // @resume
> // On Resume, starts a timer pushing {index : #} every second
> // Fire readable after 1.5 second
> // Clear interval after 5 seconds
> // So basically, a consumer should receive about 5 messages
> R.prototype.resume= function(){
> console.log("R.resume");
> var self= this;
> this.timer = setInterval(this.pusher.bind(this), 1000);
> setTimeout(this.emit.bind(this, "readable"),1500);
> setTimeout(this.emit.bind(this, null), 5000);
> setTimeout(function(){clearInterval(self.timer)}, 5000);
> }
>
>
> // The function invoked by resume to push messages
> R.prototype.pusher = function(){
> console.log("R.push");
> var msg = {index : this.index++};
> this.push(msg);
> };
>
> R.prototype._read= function(){
> var self= this;
> console.log("R._read");
> }
>
> R.prototype.pause= function(){
> console.log("R.pause");
> clearInterval(this.timer);
> }
> if (!module.parent){
> var r = new R();
> // This is never called ?!
> r.on("data", function(data){
> console.log("received data", data);
> });
>
> // This works but good luck to manage edge cases !
> //r.on('readable', function() {
> // var chunk;
> // while (null !== (msg = r.read())) {
> // console.log('got %d bytes of data', msg);
> // }
> //});
> }
>
>
> The 'data' listener never gets called.
> The while loop works after 'readable' event gets fired but does not look
> like what doc says.
>
> Any help very welcome !
>
>
>
>
>
>
>
>
--
Job board: http://jobs.nodejs.org/
New group rules:
https://gist.github.com/othiym23/9886289#file-moderation-policy-md
Old group rules:
https://github.com/joyent/node/wiki/Mailing-List-Posting-Guidelines
---
You received this message because you are subscribed to the Google Groups
"nodejs" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
To view this discussion on the web visit
https://groups.google.com/d/msgid/nodejs/fd579fb0-d1b3-48c3-afc3-2a9e8af2e8a8%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
