1.3.0 • Published 8 years ago

bucket_emitter v1.3.0

Weekly downloads
3
License
ISC
Repository
github
Last release
8 years ago

bucket_emitter

it is a simple library to make an array of bulk data from data streaming. The data array will be emitted when time has expired or data has filled.

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);
  });
});
1.3.0

8 years ago

1.2.4

10 years ago

1.2.3

10 years ago

1.2.2

10 years ago

1.2.1

10 years ago

1.2.0

10 years ago

1.1.0

10 years ago

1.0.1

10 years ago

1.0.0

10 years ago