diff --git a/lib/services/address/index.js b/lib/services/address/index.js index 636020c4..7835d888 100644 --- a/lib/services/address/index.js +++ b/lib/services/address/index.js @@ -777,7 +777,8 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre next(); }, // stream the rest of the confirmed txids out of the address index - async function(next) { + function(next) { + console.debug("NEXT@781", next); var txIdTransformStream = new Transform({ objectMode: true }); @@ -807,7 +808,7 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre txidStream.pipe(txIdTransformStream); q.drain = function(){ - console.debug("Q-DRAIN"); + console.debug("Q-DRAIN", next); next(); };