node-cypher
Advanced tools
Comparing version 0.1.0 to 0.1.1
@@ -101,7 +101,9 @@ var _ = require('underscore'); | ||
if (pending.length==0){ | ||
return setImmediate(done,null); | ||
setImmediate(done,null); | ||
} else if (pending.length==1){ | ||
var item = pending.pop(); | ||
client.query(item.query,item.params,item.cb); | ||
return setImmediate(done,null); | ||
client.query(item.query,item.params,function(err,res){ | ||
setImmediate(item.cb,err,res); | ||
setImmediate(done,null); | ||
}); | ||
} else { | ||
@@ -113,2 +115,3 @@ client.queryBatch(pending,function(err,results){ | ||
}); | ||
pending = self._requests = []; | ||
setImmediate(done,err); | ||
@@ -134,3 +137,3 @@ return false; | ||
pending.reverse(); | ||
setImmediate(runIteration); | ||
runIteration(); | ||
} else { | ||
@@ -141,2 +144,3 @@ results.forEach(function(item,index){ | ||
}); | ||
pending = self._requests = []; | ||
setImmediate(done,null); | ||
@@ -148,3 +152,3 @@ } | ||
} | ||
setImmediate(runIteration) | ||
runIteration(); | ||
}; | ||
@@ -151,0 +155,0 @@ |
{ | ||
"name": "node-cypher", | ||
"version": "0.1.0", | ||
"version": "0.1.1", | ||
"description": "Cypher-only interface to neo4j over http, optimized for volume. Configurably batches and retries items to increase overall throughput.", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
14277
214