The standard way would be to define a readable stream with a _read method:
var Stream = require('stream');
var myStream = new Stream.Readable();
var i = 0;
var data = [1, 2, 3, 4];
myStream._read = function(size) {
var pushed = true;
while (pushed && i < data.length) {
pushed = this.push(data[i++]);
}
if (i === data.length) {
this.push(null);
}
};
myStream.pipe(somewhere);
However, you can also use event-stream's readArray method:
var es = require('event-stream');
var data = [1, 2, 3, 4];
var myStream = es.readArray(data);
myStream.pipe(somewhere);