Update index.js
This commit is contained in:
parent
1d53646101
commit
8d4f9f5a6e
@ -1001,16 +1001,14 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
|
|||||||
//wait for queue to complete
|
//wait for queue to complete
|
||||||
function(next) {
|
function(next) {
|
||||||
|
|
||||||
if(!q.started){ //no tx
|
console.debug("WAITING FOR QUEUE TO COMPLETE", q.started)
|
||||||
console.debug("NO QUEUE, END");
|
|
||||||
|
if(!q.started) //No tx in query
|
||||||
return next();
|
return next();
|
||||||
}
|
|
||||||
|
|
||||||
console.debug("WAITING FOR DRAIN")
|
else
|
||||||
q.drain = ()=> {
|
q.drain = () => next();
|
||||||
console.debug("END-DRAIN");
|
|
||||||
next();
|
|
||||||
};
|
|
||||||
}
|
}
|
||||||
|
|
||||||
], callback);
|
], callback);
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user