readable.js

readable.js

var _ = require('util');
var Readable = require('stream').Readable;

function MyReader (options) {
    if (!(this instanceof MyReader)) {
        return new MyReader(options);
    }

    Readable.call(this, options);

    this.idx = 0;
    this.buffer = [
        "a",
        "b",
        "c",
        "d",
        "e",
        "f"
    ];
}

_.inherits(MyReader, Readable);

MyReader.prototype._read = function (n) {
    var len = this.buffer.length;
    if (this.idx < len - 1) {
        this.push(this.buffer[this.idx]);
        this.idx++;
    } else {
        this.push(null);
    }
}


MyReader().pipe(process.stdout);