readable streams

stream_readable.js

const Readable = require('stream').Readable;
const util = require('util');

function Reader() {
    Readable.call(this);
    this.arr = [0,1,2,3,4,5,6,7,8,9,10,11];
}

util.inherits(Reader, Readable);

Reader.prototype._read = function() {
    let element = this.arr.pop()

    return this.push(element? element.toString(): null);
};

let reader = new Reader();
reader.setEncoding('utf8');

reader.on('data', chunk => console.log(chunk));