diff --git a/lib/services/address/index.js b/lib/services/address/index.js index cc9c34e9..5c8e83e6 100644 --- a/lib/services/address/index.js +++ b/lib/services/address/index.js @@ -737,10 +737,10 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre }, 4); - q.pause(); //pause and wait until queue is set - q.empty(() => console.debug("Q-EMPTY")); + q.pause(); //pause and wait until queue is set + function process_chunk(err, tx){ console.debug("PROCESS_CHUNK:", q.length(), tx.txid()); streamer(err, tx);