RanchiMall/flocore-node
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
sairajzero 2023-02-02 18:40:42 +05:30
parent 8ca0688153
commit 0b0ba0d630
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
lib/services/address/index.js
View File

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