Comparing version 1.0.0-beta.2 to 1.0.0-beta.3
@@ -22,2 +22,4 @@ var big = require('big.js'); | ||
function sendAll(requests, fnName, concurrency, callback) { | ||
if (!Array.isArray(requests)) console.log(fnName); | ||
if (typeof concurrency === 'function') { | ||
@@ -47,2 +49,4 @@ callback = concurrency; | ||
responses.forEach(function(response) { | ||
if (!response) response = { error: null, data: null }; | ||
errors.push(response.error); | ||
@@ -69,3 +73,3 @@ data.push(response.data); | ||
var unprocessedCount = unprocessed.filter(function(req) { return !!req; }).length; | ||
if (unprocessedCount) unprocessed.sendAll = sendAll.bind(unprocessed, fnName); | ||
if (unprocessedCount) unprocessed.sendAll = sendAll.bind(null, unprocessed, fnName); | ||
@@ -72,0 +76,0 @@ var errorCount = errors.filter(function(err) { return !!err; }).length; |
{ | ||
"name": "dyno", | ||
"version": "1.0.0-beta.2", | ||
"version": "1.0.0-beta.3", | ||
"description": "Simple DynamoDB client", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -508,4 +508,7 @@ var AWS = require('aws-sdk'); | ||
AWS.Request.prototype.send = original; | ||
assert.end(); | ||
unprocessed.sendAll(function(err) { | ||
assert.ifError(err, 'successful .sendAll on unprocessed requestSet'); | ||
AWS.Request.prototype.send = original; | ||
assert.end(); | ||
}); | ||
}); | ||
@@ -512,0 +515,0 @@ }); |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
122611
2246