diff --git a/lib/node.js b/lib/node.js index 860ae14..2ca149f 100644 --- a/lib/node.js +++ b/lib/node.js @@ -713,6 +713,10 @@ Node.prototype.setWatches = function() self._latestQueue.push(hash); }, self._chan_min_time); + this._debouncedPending = debounce(function() { + self.getPending(); + }, 5); + try { this.chainFilter = web3.eth.filter('latest'); this.chainFilter.watch( function (err, hash) @@ -792,9 +796,7 @@ Node.prototype.setWatches = function() } else { - debounce(function() { - self.getPending(); - }, 5); + self._debouncedPending(); } });