This commit is contained in:
sairajzero 2023-02-02 18:30:32 +05:30
parent bb54d958bb
commit 6347ae261f

View File

@ -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) {