Fixed missed call to next.
This commit is contained in:
parent
5d0923a9d1
commit
b1fe37c260
@ -66,7 +66,7 @@ AddressService.prototype.getAddressHistory = function(addresses, options, callba
|
||||
addresses = [addresses];
|
||||
}
|
||||
|
||||
async.eachLimit(addresses, 8, function(address, next) {
|
||||
async.eachSeries(addresses, function(address, next) {
|
||||
|
||||
self._getAddressTxidHistory(address, options, next);
|
||||
|
||||
@ -262,6 +262,8 @@ AddressService.prototype.getAddressUnspentOutputs = function(address, options, c
|
||||
|
||||
});
|
||||
|
||||
next();
|
||||
|
||||
});
|
||||
|
||||
},
|
||||
|
||||
@ -94,10 +94,6 @@ MempoolService.prototype.onReorg = function(args, callback) {
|
||||
|
||||
var removalOps = [];
|
||||
|
||||
if (!this._enabled) {
|
||||
return callback(null, removalOps);
|
||||
}
|
||||
|
||||
var oldBlockList = args[1];
|
||||
|
||||
for(var i = 0; i < oldBlockList.length; i++) {
|
||||
@ -155,10 +151,6 @@ MempoolService.prototype.onBlock = function(block, callback) {
|
||||
var self = this;
|
||||
var ops = [];
|
||||
|
||||
if (!self._enabled) {
|
||||
return callback(null, ops);
|
||||
}
|
||||
|
||||
for(var i = 0; i < block.txs.length; i++) {
|
||||
var tx = block.txs[i];
|
||||
|
||||
|
||||
@ -34,6 +34,9 @@ describe('DB', function() {
|
||||
describe('#start', function() {
|
||||
it('should start the db service by creating a db dir, ' +
|
||||
' if necessary, and setting the store', function(done) {
|
||||
|
||||
dbService._setDataPath();
|
||||
|
||||
dbService.start(function() {
|
||||
dbService._store.should.be.instanceOf(Levelup);
|
||||
done();
|
||||
|
||||
Loading…
Reference in New Issue
Block a user