Node.js - Simple Stream Readable Example

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

var count = 0;

var readStream = new Readable({
    objectMode: true,
    read: function () {
        count += 1;
        if (count === 10) {
            this.push(null);
        } else {
            this.push(count);
        }
    }
});

readStream.on('data', function (chunk) {
    console.log(chunk);
    /*
    // Асинхронное чтение.
    setTimeout(function () {
        readStream.read();
    }, 1000);
    */
});

readStream.on('end', function (chunk) {
    console.log('END');
});

// Синхронное чтение.
console.log(readStream.read());
console.log(readStream.read());
console.log(readStream.read());

/*
// Старт асинхронного чтения.
readStream.read();
*/