This commit is contained in:
sairajzero 2023-02-02 18:57:33 +05:30
parent 14e9371306
commit 450e6b9d21

View File

@ -217,6 +217,7 @@ AddressService.prototype.getAddressHistory = function(addresses, options, stream
}, function(err) { }, function(err) {
console.debug("END @getAddressHistory");
if (err) { if (err) {
return callback(err); return callback(err);
} }
@ -911,7 +912,10 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
}); });
txIdTransformStream.on('end', function() { txIdTransformStream.on('end', function() {
q.drain = next; q.drain = (e, d)=> {
console.debug("END-DRAIN", d_count, td_count);
next(e, d);
};
//q.resume(); //q.resume();
}); });