only emit new transactions.

This commit is contained in:
Christopher Jeffrey 2016-01-29 16:00:40 -08:00
parent 1115468f05
commit 3959b9cf5d

View File

@ -815,10 +815,13 @@ Pool.prototype._createPeer = function _createPeer(backoff, priority) {
});
peer.on('tx', function(tx) {
self._response(tx);
self._addTX(tx);
var requested, added;
self.emit('tx', tx, peer);
requested = self._response(tx);
added = self._addTX(tx);
if (added || tx.block)
self.emit('tx', tx, peer);
if (!self.options.fullNode && tx.block)
self.emit('watched', tx, peer);