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

Update index.js

Browse Source
This commit is contained in:
sairajzero 2023-02-05 16:13:41 +05:30
parent 5e6340be78
commit ed79adb910
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -876,7 +876,7 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
//q.pause(); //pause and wait until queue is set
function chunkCallback(err, tx){
console.debug("CHUNK", td_count, q.length());
console.debug("CHUNK", td_count, q.length(), q.idle());
if(!err && !tx) //no error or tx data (duplicate calls will have empty tx value)
return;
@ -944,11 +944,7 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
});
txIdTransformStream.on('end', function() {
q.drain = (e, d)=> {
console.debug("END-DRAIN", e, d, d_count, td_count);
next();
};
//q.resume();
next();
});
txIdTransformStream._transform = function(chunk, enc, cb) {
@ -991,6 +987,15 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
next();
},
//wait for queue to complete
function(next) {
console.debug("WAITING FOR DRAIN")
q.drain = ()=> {
console.debug("END-DRAIN", d_count, td_count);
next();
};
}
], callback);
}