diff --git a/lib/mbtiles.js b/lib/mbtiles.js index 6647b71..b178a07 100644 --- a/lib/mbtiles.js +++ b/lib/mbtiles.js @@ -625,7 +625,11 @@ MBTiles.prototype.geocoderDataIterator = function(type) { var doneSentinel = {}; var _this = this; + var sending = false; var sendIfAvailable = function() { + if (sending) return; + sending = true; + while (nextQueue.length && dataQueue.length) { var nextCb = nextQueue.shift(), data; if (dataQueue[0] == doneSentinel) { @@ -637,6 +641,8 @@ MBTiles.prototype.geocoderDataIterator = function(type) { nextCb({value: {shard: data.shard, data: zlib.inflateSync(data.data)}, done: false}); } } + + sending = false; } var refilling = false;