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

log

Browse Source
This commit is contained in:
sairajzero 2023-02-05 06:03:14 +05:30
parent 9b59e5791a
commit 5e6340be78
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -891,6 +891,9 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
streamer(err, tx); streamer(err, tx);
if((err || options.flag_stop) && q.idle()){ if((err || options.flag_stop) && q.idle()){
console.debug("KILL", options.flag_stop)
q.kill(); q.kill();
return callback(); return callback();
@ -950,8 +953,11 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
txIdTransformStream._transform = function(chunk, enc, cb) { txIdTransformStream._transform = function(chunk, enc, cb) {
if(options.flag_stop)//stop data query if(options.flag_stop){
//stop data query
console.debug("FLAG:", options.flag_stop)
return txIdTransformStream.unpipe(); return txIdTransformStream.unpipe();
}
var txInfo = self._encoding.decodeAddressIndexKey(chunk); var txInfo = self._encoding.decodeAddressIndexKey(chunk);
q.push({ txid: txInfo.txid, height: txInfo.height }, chunkCallback); q.push({ txid: txInfo.txid, height: txInfo.height }, chunkCallback);