This commit is contained in:
sairajzero 2023-01-28 01:41:49 +05:30
parent 66fa217f10
commit 09a934f65b

View File

@ -777,7 +777,7 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
next();
},
// stream the rest of the confirmed txids out of the address index
function(next) {
async function(next) {
var txIdTransformStream = new Transform({ objectMode: true });
@ -806,11 +806,9 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
var txidStream = self._getTxidStream(address, options);
txidStream.pipe(txIdTransformStream);
q.drain(function (e, d){
console.debug("Q-DRAIN", e, d);
next(e, d);
});
await q.drain();
console.debug("Q-DRAIN");
next();
}
], callback);