Readable stream gets called infinitely?

[jmcbee]

Hi, forgive me for my noobness. I am trying to figure out, what is happening? I created a readable stream and it gets called infinitely.

es.readable(function(count, next) {
  next(null, 'hello world');
}).pipe(es.log('test'));

Why does it do that?

[dominictarr]

you need to do this.emit('end') at some point, it's documented.
https://github.com/dominictarr/event-stream/#readable-asyncfunction

[jmcbee]

Thanks!