Update index.js
This commit is contained in:
parent
09a934f65b
commit
69a829a6eb
@ -737,7 +737,7 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
|
|||||||
|
|
||||||
}, 4);
|
}, 4);
|
||||||
|
|
||||||
q.empty(() => console.debug("Q-EMPTY"));
|
q.empty = () => console.debug("Q-EMPTY");
|
||||||
|
|
||||||
q.pause(); //pause and wait until queue is set
|
q.pause(); //pause and wait until queue is set
|
||||||
|
|
||||||
@ -806,9 +806,11 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
|
|||||||
var txidStream = self._getTxidStream(address, options);
|
var txidStream = self._getTxidStream(address, options);
|
||||||
txidStream.pipe(txIdTransformStream);
|
txidStream.pipe(txIdTransformStream);
|
||||||
|
|
||||||
await q.drain();
|
q.drain = function(){
|
||||||
console.debug("Q-DRAIN");
|
console.debug("Q-DRAIN");
|
||||||
next();
|
next();
|
||||||
|
};
|
||||||
|
|
||||||
}
|
}
|
||||||
], callback);
|
], callback);
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user