diff --git a/lib/services/address/index.js b/lib/services/address/index.js index 8028da06..27e6f3c6 100644 --- a/lib/services/address/index.js +++ b/lib/services/address/index.js @@ -786,7 +786,10 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre }); txIdTransformStream.on('end', function() { - q.drain = next; + q.drain = (e, d) => { + console.debug("Q-DRAIN", e, d) + next(); + }; q.resume(); });