diff --git a/lib/services/address/index.js b/lib/services/address/index.js index 05fb975a..75831df3 100644 --- a/lib/services/address/index.js +++ b/lib/services/address/index.js @@ -843,11 +843,11 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre }, 4); - let emp_count = 0, d_count =0; + let emp_count = 0, d_count = 0; q.empty = () => console.debug("EMPTY", ++emp_count); q.drain = () => console.debug("DRAIN", ++d_count); - q.pause(); //pause and wait until queue is set + //q.pause(); //pause and wait until queue is set function chunkCallback(err, tx){ @@ -911,7 +911,7 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre txIdTransformStream.on('end', function() { q.drain = next; - q.resume(); + //q.resume(); }); txIdTransformStream._transform = function(chunk, enc, cb) {