node-tsguru
Advanced tools
Comparing version 1.6.0 to 1.6.1
23
index.js
@@ -190,12 +190,2 @@ var MAX_BODY_SIZE = 1024 * 16; | ||
var e = new events.EventEmitter(); | ||
var intervalObject = setInterval(function() { | ||
e.emit("flush", bufferLength); | ||
flush(function(err) { | ||
if (err) { | ||
e.emit("error", err); | ||
} else { | ||
e.emit("flushed"); | ||
} | ||
}); | ||
}, params.delay || 250); | ||
function flush(cb) { | ||
@@ -229,2 +219,13 @@ if (bufferLength === 0) { | ||
} | ||
function flushOrEmit() { | ||
e.emit("flush", bufferLength); | ||
flush(function(err) { | ||
if (err) { | ||
e.emit("error", err); | ||
} else { | ||
e.emit("flushed"); | ||
} | ||
}); | ||
} | ||
var intervalObject = setInterval(flushOrEmit, params.delay || 250); | ||
function append(csv) { | ||
@@ -236,3 +237,3 @@ if (intervalObject === undefined) { | ||
if ((bufferLength + length) > MAX_BODY_SIZE) { | ||
flush(); | ||
flushOrEmit(); | ||
} | ||
@@ -239,0 +240,0 @@ buffer += csv; |
{ | ||
"name": "node-tsguru", | ||
"version": "1.6.0", | ||
"version": "1.6.1", | ||
"description": "TimeSeries.Guru Node.js client", | ||
@@ -5,0 +5,0 @@ "keywords": ["time", "series", "timeseries", "time-series", "guru", "timeseriesguru", "timeseries.guru", "client"], |
34748
809