		@@ -90,10 +90,9 @@ module.exports = require('theory')
		store.wait = null;
		console.log('************* chug chug chug *****************');
		console.log('************* save', where, '*****************');
		a.obj(store.batch).each(function(g,where){
		if(!g \|\| !where){ return }
		console.log('save', where, (g && g.packageson && g.packageson._));
		s3(opt.s3.bucket(where)).put(opt.s3.key(where),g,function(e,r){
		a.list(store.batched[where]).each(function(cb){
		if(a.fns.is(cb)){ cb(e,r) }
		console.log('batch save s3 done', where);
		console.log('* end *');
		});
		@@ -103,3 +102,2 @@ delete store.batched[where];
		});
		console.log('* end *');
		}
		@@ -147,3 +145,2 @@ store.set = function(key, value, cb, fn){
		console.log('via s3', where);
		console.log(e,r, t);
		if(e \|\| !r){ return cb(null, e) }
		@@ -174,3 +171,2 @@ store.set(where, (t \|\| a.text.ify(r)));
		shot.spray.action = function(m){
		console.log('spray', m);
		if(!m \|\| !m.how){ return }
		@@ -218,3 +214,5 @@ if(m.where && m.where.mid){
		if(opt.src && opt.src.send){
		var m = {count: 1};
		opt.src.send({count: 1});
		console.log("send that pumping message!", m);
		}
		@@ -221,0 +219,0 @@ })();

test/tests.js

		@@ -8,6 +8,6 @@ module.exports=require('theory')
		return shot.spray(function(g, m, done){
		console.log('>>>>>>>>>> gun');
		//console.log('>>>>>>>>>> gun');
		var gPrime = {};
		done(gPrime); // allow me to send custom modified filtered version
		console.log(g());
		//console.log(g());
		});
		@@ -14,0 +14,0 @@ }

gun - npm Package Compare versions

New alerts