This commit is contained in:
sairajzero 2023-02-05 19:09:49 +05:30
parent 85c1c02c74
commit cb89be8263

View File

@ -881,14 +881,10 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
}, 4);
let emp_count = 0, d_count = 0;
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
function chunkCallback(err, tx){
console.debug("CHUNK", td_count, q.length(), q.killed);
if(q.killed || (!err && !tx)) //no error or tx data (duplicate calls will have empty tx value)
return;
@ -925,7 +921,9 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
self._transaction.getTransaction(options.after, options, function(err, tx) {
if(tx && tx.confirmations && tx.height > options.start) {
if(!tx) console.debug(options.after + "Not found");
if(tx && tx.confirmations && tx.height >= options.start) {
options.start = tx.height;