Authored by htoooth

add immediate options

Showing 1 changed file with 6 additions and 1 deletions
... ... @@ -32,6 +32,10 @@ class Sender extends EventEmitter {
return;
}
if (this.options.immediate) {
return;
}
// pre duration send array
setInterval(() => {
this._send();
... ... @@ -61,7 +65,8 @@ class Sender extends EventEmitter {
message.time = message.time || new Date().getTime() * 1000000;
debug('add message! %O', message);
this.batchMessages.push(message);
if (this.batchMessages.length > this.options.records) {
if ((this.batchMessages.length > this.options.records) || this.options.immediate) {
this._send();
debug('batchMessages over records and sent!');
}
... ...