mongopatch/bin/t.js

var mongojs = require('mongojs');
var stream = require('stream-wrapper');

var db = mongojs('mongodb://app2:U6G3v3rE9wgdzGTfQMgi@economic-staging-eu.m0.mongolayer.com:27017,economic-staging-eu1.mongolayer.com:27017,economic-staging-eu.arbiter.mongolayer.com:27017/economic-staging-eu-2?safe=true&slaveOk=true&journal=true');

var invoices = db.collection('invoices').find();

invoices.on('end', function() {
	console.log('---- end');
});

var once = function() {
	var i = 0;

	return stream.transform({ objectMode: true }, function(data, encoding, callback) {
		/*console.log('---- once', data);
		if(called) return;

		called = true;
		callback(null, data);*/

		setTimeout(function() {
			console.log(++i);
			callback(null, data);
		}, 1000);
	});
};

var o = once();
o.resume();

invoices.pipe(o);