diff --git a/lib/services/address/index.js b/lib/services/address/index.js index 2c8dbccc..080c8c4d 100644 --- a/lib/services/address/index.js +++ b/lib/services/address/index.js @@ -811,8 +811,9 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre //declare the queue to process tx data var tmpTxList = {}; //store processed txid temporarily to ignore duplication + let td_count = 0; //test var q = async.queue(function(id, cb) { - + td_count++; //test //duplication finding if(id.txid in tmpTxList){ @@ -844,8 +845,8 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre }, 4); let emp_count = 0, d_count = 0; - q.empty = () => console.debug("EMPTY", ++emp_count, q.length()); - q.drain = () => console.debug("DRAIN", ++d_count, q.length()); + q.empty = () => console.debug("EMPTY", ++emp_count, td_count); + q.drain = () => console.debug("DRAIN", ++d_count, td_count); //q.pause(); //pause and wait until queue is set