This commit is contained in:
sairajzero 2023-01-28 01:10:19 +05:30
parent f899f5671d
commit 9e0ebda278

View File

@ -314,8 +314,6 @@ AddressService.prototype.getAddressSummary = function(address, options, streamer
if(tx)
self._aggregateAddressSummaryResult(tx, address, result, options);
console.debug(result.txApperances);
streamer(null, tx);
}, function(err) {
@ -746,6 +744,7 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
streamer(err, tx);
if(err){
console.debug(err);
q.kill();
return callback();
@ -804,7 +803,10 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
var txidStream = self._getTxidStream(address, options);
txidStream.pipe(txIdTransformStream);
q.drain(next);
q.drain(function (e, d){
console.debug("Drain reached...", e, d);
next(e, d);
});
}
], callback);