node-cypher
Advanced tools
Comparing version 0.0.3 to 0.0.4
@@ -59,3 +59,3 @@ var _ = require('underscore'); | ||
var self = this ; | ||
var pending = self._requests ; | ||
var pending = self._requests.splice(0,Infinity) ; // empty out batch _requests and add to pending array. | ||
var done = cb || function(){}; | ||
@@ -90,2 +90,6 @@ function runIteration () { | ||
if ( wasFailedRequest ) { | ||
// every time a failing item is removed from the batch, reverse | ||
// the local "pending" queue. We want to continuously remove | ||
// failable items from the tail, normalizing batch sizes if possible. | ||
pending.reverse(); | ||
setImmediate(runIteration); | ||
@@ -92,0 +96,0 @@ } else { |
{ | ||
"name": "node-cypher", | ||
"version": "0.0.3", | ||
"version": "0.0.4", | ||
"description": "Cypher-only interface to neo4j over http, optimized for speed", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
8390
207