bucket_emitter

Simple library to generate bulk array from streaming data.

Usage

var bucket_emitter = require('bucket-emitter')
var bucket = bucket_emitter.create({
	timeout: 1000, //if there's no data input until timeout, emit data forcefully.
	maxSize: 10, //data emitted count
	useInterval: false //if this value is true, data event is emitted even If new data is pushed.
});

for (var i=0; i<1024; ++i) {
	setTimeout(function() {
		bucket.push(++i);
	}, 0);
}

bucket.on('data', function(fulfilled) {
  console.log(fulfilled);
}).on('error', function(err) {
  console.log(err);
});

process.on('beforeExit', function() {
  bucket.close(function(leftData) {
    console.log(leftData);
  });
});